Kafka：提供配置'compression.codec'，但不是已知的配置

Question

我正在運行使用0.10.1.0的Kafka java客戶端。 按照配置這裏 https://cwiki.apache.org/confluence/display/KAFKA/Compression

建議我把

compression.codec=1 

在生產性能。但是當我運行時，生產者 提供配置compression.codec，但不是已知的配置 顯示此警告。

按照API文檔，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來代替。