在 kafka 生产者中将 COMPRESSION_TYPE_CONFIG 启用为“gzip”后，我看不到消费者端压缩的数据

Question

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

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

这是我在生产者配置中添加的代码，但是当我将消息发送到主题以及在消费者端阅读它们时，消息不会被压缩。任何人都可以建议如何在 kafka 的生产者端进行消息压缩。 我正在使用 JAVA 和 Springboot。

提前致谢。

Answer 1

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

使用压缩（例如，在生产者端，就像您所做的那样）意味着数据在物理存储在磁盘上时会被压缩。您可以通过查看 Kafka 主题的数据日志来检查这一点，并在使用和不使用压缩时比较内容。