我是个新手 Kafka 。使用kafka 0.9.0时，我可以通过设置 compression.type Kafka制作人的财产。
假设我使用 snappy 压缩在我的producer中，当使用某个kafka消费者从kafka消费消息时，我应该做些什么来解码snappy中的数据，还是kafka消费者的一些内置功能？
在office文档中，我找不到任何与kafka consumer中的编码相关的属性（它只与生产者相关）。
有人能把这个弄清楚吗？
我是个新手 Kafka 。使用kafka 0.9.0时，我可以通过设置 compression.type Kafka制作人的财产。
假设我使用 snappy 压缩在我的producer中，当使用某个kafka消费者从kafka消费消息时，我应该做些什么来解码snappy中的数据，还是kafka消费者的一些内置功能？
在office文档中，我找不到任何与kafka consumer中的编码相关的属性（它只与生产者相关）。
有人能把这个弄清楚吗？
1条答案
按热度按时间relj7zay1#
As mentioned in their wiki Page,there is no need for any decompression logic on the Consumer side:请查看下面的wiki页面：
https://cwiki.apache.org/confluence/display/kafka/compression
使用者接收到的主题数据可能包含压缩消息和未压缩消息。这个
consumer迭代器transparently
decompresses compressed仅返回uncompressed message.