Я пытаюсь зеркально отразить темы со сжатием. Type = gzip, но сообщения приходят на целевой кластер без сжатия. Я использую разъем kafka для запуска MM2.
Я пробовал эти настройки без успеха:
compression.type = gzip
producer.compression.type = gzip
target.compression.type = gzip
Я проверяю сообщения в целевом кластере, используя:
/bin/kafka-run-class.sh kafka.tools.DumpLogSegments --files /path_to_log/00000000000000000000.log --print-data-log | grep compresscodec
Кто-нибудь сталкивался с этой проблемой с MM 2? Или любой совет?