Сжатие сообщений Kafka не работает (уровень брокера) ⇐ Python

[Anonymous]

Я добавил сжатие сообщений журнала на уровне брокера compress.type=zstd для всех трех брокеров без каких-либо изменений на уровне брокера.
Когда я пытался прочитать сообщения из моего клиента Python для Кафки у меня начались таймауты. С этого момента Потребитель не ответил никакими сообщениями. Я отменил это изменение на всех трех брокерах и теперь снова могу получить доступ к сообщениям.
Где я ошибся и как правильно включить сжатие журналов сообщений? Должен ли я теперь добавить сжатие и на уровне производителя? Заранее спасибо.

Подробнее здесь: https://stackoverflow.com/questions/790 ... oker-level