Kafka Streams: topic.compression.type не известный конфиг

Question

Добавление конфигурации сжатия в Kafka Streams, аналогично этой ссылке :

properties.put(StreamsConfig.topicPrefix(TopicConfig.COMPRESSION_TYPE_CONFIG), "snappy");

, но я вижу следующие сообщения WARN в журнале:

[2018-11-19 23:52:10,158] WARN The configuration 'topic.compression.type' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig)
[2018-11-19 23:52:10,158] WARN The configuration 'topic.compression.type' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig)
[2018-11-19 23:52:10,194] WARN The configuration 'topic.compression.type' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig)
[2018-11-19 23:52:10,194] WARN The configuration 'topic.compression.type' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig)
[2018-11-19 23:52:10,209] WARN The configuration 'topic.compression.type' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig)
[2018-11-19 23:52:10,209] WARN The configuration 'topic.compression.type' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig)
[2018-11-19 23:52:10,221] WARN The configuration 'topic.compression.type' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig)
[2018-11-19 23:52:10,221] WARN The configuration 'topic.compression.type' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig)

Эта настройка не соблюдается?Разве это не хорошо выражено?

Answer 1

Вы можете игнорировать эти предупреждения.«Проблема» заключается в том, что параметр конфигурации раздела копируется в конфиги внутренних клиентов, и они не знают имя параметра и, следовательно, ПРЕДУПРЕЖДАЮТ о нем.Однако эти конфиги должны быть установлены на клиентах, потому что клиенты будут «пересылать» эти конфиги другим частям в кодовой базе, которые знают, как их использовать.

Это немного прискорбно и известная проблема (ноне легко обратиться).Существует JIRA для этой проблемы: https://issues.apache.org/jira/browse/KAFKA-6793