java—在kafka producer中将压缩类型配置启用为“gzip”之后，我无法在使用者端看到压缩的数据

h7appiyu 于 2021-06-04 发布在 Kafka

关注(0)|答案(1)|浏览(558)

我想压缩Kafka的信息。所以我在producer端启用了压缩类型gzip，并且没有更改server.properties上的任何内容。

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

这是我在producer配置中添加的代码，但是当我将消息发送到主题时，以及当我在comsumer端读取它们时，消息不会被压缩。有人能建议如何在Kafka的生产者端进行消息压缩吗。我正在使用java和springboot。
提前谢谢。

1条答案

使用者自动检测应用的压缩并解压缩数据。
使用压缩（例如，在生产者方面，因为你已经这样做了）意味着数据压缩时，存储在磁盘上的物理。你可以检查到你的Kafka主题的数据日志，比较使用和不使用压缩时的内容。