KafkaSpout(Storm) 解压消息

【问题标题】：KafkaSpout(Storm) uncompression messagesKafkaSpout(Storm) 解压消息
【发布时间】：2016-06-29 10:57:58
【问题描述】：

我正在使用 KafkaSpout 来使用来自 Kafka 的消息。

消息由org.apache.kafka.clients.producer.KafkaProducer 生成带gzip压缩props.put(ProducerConfig.COMPRESSION_TYPE_CONFIG, "gzip");

如何在 KafkaSpout 中设置压缩类型来消费未压缩的消息？

【问题讨论】：

【解决方案1】：

gzip 压缩是自动处理的。如果它是一个文本文件，那么您可以直接使用输入流进行读取，或者对于 XML 文件，您可以将其解析为常规文件。

属性props.put(ProducerConfig.COMPRESSION_TYPE_CONFIG, "gzip"); 不是必需的。

如果有任何错误，请发布。

【讨论】：