kafka中的「offsetsets.topic.compression.codec」究竟有什麼作用？

Question

最近我們開始在元數據上得到MessageSizeTooLargeException，所以我們啓用了offsetsets.topic.compression.codec = 1來啓用gzip壓縮，但是代理中rate/messages的總體字節速率並沒有改變。我錯過了什麼嗎？是否還有其他一些財產需要更改？

此編解碼器如何工作？

我們是否需要爲消費者和生產者添加一些財產？我剛剛在經紀商中啓用了此功能。

Answer 1

offsets.topic.compression.codec僅用於內部偏移主題（即__consumer_offsets）。這些用戶級主題沒有用處。如何避免MessageTooLargeException/RecordTooLargeException，請參閱Kafka: Sending a 15MB message。