最近,我们开始在元数据上获取messagesizetoolargeexception,因此我们启用了offsets.topic.compression.codec=1来启用gzip压缩,但是rate/messages-in-rate到代理的总字节数没有改变。我错过什么了吗?有其他需要改变的财产吗?
这个编解码器是如何工作的?
我们是否也需要在消费者和生产者身上增加一些财产?我刚刚在代理上启用了这个。
最近,我们开始在元数据上获取messagesizetoolargeexception,因此我们启用了offsets.topic.compression.codec=1来启用gzip压缩,但是rate/messages-in-rate到代理的总字节数没有改变。我错过什么了吗?有其他需要改变的财产吗?
这个编解码器是如何工作的?
我们是否也需要在消费者和生产者身上增加一些财产?我刚刚在代理上启用了这个。
1条答案
按热度按时间up9lanfz1#
offsets.topic.compression.codec
仅适用于内部偏移主题(即消费偏移)。对于那些用户级的主题是没有用的。请参阅kafka:发送一条15mb的消息,说明如何避免messagetoolargeexception/recordtoolargeexception。