Kafka中的“偏移量.主题.压缩.编解码器”实际上是做什么的?

lyr7nygr  于 2021-06-07  发布在  Kafka
关注(0)|答案(1)|浏览(295)

最近,我们开始在元数据上获取messagesizetoolargeexception,因此我们启用了offsets.topic.compression.codec=1来启用gzip压缩,但是rate/messages-in-rate到代理的总字节数没有改变。我错过什么了吗?有其他需要改变的财产吗?
这个编解码器是如何工作的?
我们是否也需要在消费者和生产者身上增加一些财产?我刚刚在代理上启用了这个。

up9lanfz

up9lanfz1#

offsets.topic.compression.codec 仅适用于内部偏移主题(即消费偏移)。对于那些用户级的主题是没有用的。
请参阅kafka:发送一条15mb的消息,说明如何避免messagetoolargeexception/recordtoolargeexception。

相关问题