Kafka：設定 'compression.codec'が提供されましたが、既知の設定ではありません

Question

私はKafka Javaクライアントを0.10.1.0で実行しています。 はここ https://cwiki.apache.org/confluence/display/KAFKA/Compression

示唆した設定ごととして、私はプロデューサーのプロパティで

compression.codec=1 

を置きます。しかし、私が実行すると、生産者 構成compression.codecが提供されましたが、既知の設定ではありません この警告が表示されます。 APIドキュメントを1として

、http://home.apache.org/~jgus/kafka-0.10.1.0-rc0/javadoc/index.html?org/apache/kafka/clients/producer/KafkaProducer.html 唯一のプロパティ

compression.type 

が利用可能です。

また、私はcompression.topicsを置くと、同じ警告がスローされます。

プロパティcompression.typeは圧縮に十分ですか？

Answer 1

JVMベースのクライアントの場合、compression.codecはScalaプロデューサの旧設定で、Kafka 0.10から既に削除されているため、代わりにcompression.typeを使用してください。