在 kafka 生产者中启用COMPRESSION_TYPE_CONFIG "gzip"后，我无法看到在消费者端压缩的数据

Question

我想压缩kafka中的消息。所以我在生产者端启用了压缩类型为gzip，在server.propeties.上没有更改任何内容

config.put(ProducerConfig.COMPRESSION_TYPE_CONFIG, "gzip");

这是我在生产者配置中添加的代码，但当我向主题发送消息时，以及当我在消费者端阅读消息时，消息不会被压缩。有人能建议如何在卡夫卡的生产者端进行消息压缩吗。我正在使用JAVA和Springboot。

提前谢谢。

Answer 1

使用者自动检测应用的压缩并解压缩数据。

使用压缩(例如，在Producer端(意味着数据在物理存储在磁盘上时会被压缩。您可以通过查看Kafka主题的数据日志来检查这一点，并在使用和不使用压缩时比较内容。