apache-kafka - 在Kafka中哪里设置compression.type属性

Question

我想对 Kafka 消息实现压缩。为此必须设置compression.type。应该在哪个属性文件中设置？

Answer 1

如果您在生产者的配置中设置 compression.type 属性，则消息将在发送到代理之前进行压缩。如果您在服务器配置中设置此属性，则它指定如何在代理中压缩消息。在服务器端还可以指定生产者，即使用生产者设置的压缩类型。