Kafkaサーバーにはメッセージが含まれていますが、コンシューマーは受信できません（プロデューサはcompression.type = snappyを使用しています）

Question

私はKafkaの初心者です。カフカ0.9.0を使用すると、私のkafkaプロデューサーのcompression.typeプロパティを設定してコーデックを設定できます。

は、私は、私のプロデューサーでsnappy圧縮を使用する一部のカフカ - 消費者を使用してカフカからのメッセージを消費したときに、私はに何かを行う必要がありますてきぱきからデータをデコードするか、いくつかの内蔵カフカの消費者の特徴であると仮定しますか？

オフィスの文書では、私はカフカの消費者（プロデューサに関連する）の​​エンコーディングに関連するプロパティを見つけることができませんでした。

誰かがこれをクリアできますか？

Answer 1

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イテレータtransparentlydecompresses compressedデータは、uncompressed messageのみを返します。