Kafka 消息压缩不起作用（代理级别）

Question

我在所有三个代理上的代理级别compression.type=zstd 上添加了日志消息压缩，在代理级别或生产者级别上没有其他更改。

当我尝试从 kafka 的 python 客户端（消费者）读取消息时，我开始超时。从那时起，消费者没有回复任何消息。我在所有三个代理上恢复了此更改，现在我可以再次访问消息。

我哪里出错了，如何正确启用消息日志压缩？我现在也应该在生产者级别添加压缩吗？预先感谢。

Answer 1

经过几个小时的调试错误，发现只有当 Kafka 消费者通过 Python 使用 Zstd 压缩时才会出现问题。 Gzip 可以很好地使用 Broker 来压缩消息。