Где установить свойство compress.type в кафке

Question

Я хочу реализовать сжатие для кафки сообщений. Для этого должен быть установлен тип сжатия. В каком файле свойств он должен быть установлен?

Answer 1

Если вы зададите свойство compression.type в конфигурации производителя, то сообщения будут сжаты перед отправкой их брокеру. Если вы установите это свойство в конфигурации сервера, то оно указывает, как сообщения будут сжиматься в посреднике. На стороне сервера вы также можете указать producer, что означает использование типа сжатия, установленного производителем.

Answer 2

вы можете добавить ProducerConfig (https://kafka.apache.org/documentation/#producerconfigs)

поддерживает gzip, snappy, lz4

и Конфигурация темы также будут установлены. (https://kafka.apache.org/documentation/#topicconfigs)

и, Потребитель не должен быть установлен (автоопределение)