Кафка: отключить создание темы из Java

Question

Используя Kafka с библиотекой Java, я хочу отключить автоматическое создание темы (если она еще не существует).

Некоторые сайты говорят, что я должен поставить auto.create.topics.enable в false, но это не распознается в Java.

15:11:56.962 [main] WARN  o.a.k.c.consumer.ConsumerConfig -  The configuration 'auto.create.topics.enable' was supplied but isn't a known config.

В настоящее время я помещаю его в свой docker-compose как переменную окружения:

KAFKA_AUTO_CREATE_TOPICS_ENABLE: 'false'

Это работает, но я бы хотел управлятьэто от Java пользователем.

Возможно ли это?

Answer 1

Это конфигурация уровня брокера.Вы не можете позволить пользователю управлять этим из клиентских программ Java.

Поскольку свойство auto.create.topics.enable является конфигурацией посредника только для чтения, для которой требуется перезапуск служб kafka.Следовательно, невозможно обработать его со стороны клиента.

Здесь вы можете прочитать конфигурации в режиме динамического обновления: https://kafka.apache.org/documentation/#brokerconfigs