Как я могу на 100% предотвратить автоматическое создание тем? ⇐ JAVA

[Anonymous]

Я новичок в Apache Kafka. Одна из вещей, которую я изучаю, — это контроль создания тем на сервере. По сути, я хочу посмотреть, есть ли способ, позволяющий администраторам сервера на 100% контролировать существующие темы, не позволяя любому приложению, подключающемуся к серверу, создавать какие-либо темы.

Я тестирую это с помощью нескольких простых экспериментальных приложений Java/Spring Boot, которые я собрал.

Я установил auto.create.topics.enable=false на своем сервере Kafka. Это успешно предотвращает создание темы производителем Kafka, т. е. KafkaTemplate.send() завершится ошибкой, поскольку тема не существует.

Проблема в том, что потребители, похоже, все еще могут создавать темы. Когда я запускаю свое потребительское приложение для проверки концепции, все темы, которые оно слушает, автоматически создаются на сервере.

Теперь в моем приложении Spring Boot есть настройки, которые предотвращают это. Однако моя цель — обеспечить соблюдение этого правила со стороны сервера Kafka, а не полагаться на отдельные приложения для его соблюдения.

Добавлю, что я еще не настроил аутентификацию или ACL, я все еще на ранней стадии своего пути к Kafka. Так что, если это будет обрабатываться с помощью auth/ACL, это здорово.

Я думаю, что этому должно быть какое-то решение.