Мобильная версияКак я могу на 100% предотвратить автоматическое создание тем? ⇐ JAVA
-
Anonymous
Как я могу на 100% предотвратить автоматическое создание тем?
Я новичок в Apache Kafka. Одна из вещей, которую я изучаю, — это контроль создания тем на сервере. По сути, я хочу посмотреть, есть ли способ, позволяющий администраторам сервера на 100% контролировать существующие темы, предотвращая создание каких-либо тем любым приложением, подключающимся к серверу.
Я тестирую это с помощью нескольких простых экспериментальных приложений Java/Spring Boot, которые я собрал.
Я установил auto.create.topics.enable=false на своем сервере Kafka. Это успешно предотвращает создание темы производителем Kafka, т. е. KafkaTemplate.send() завершится ошибкой, поскольку тема не существует.
Проблема в том, что потребители, похоже, все еще могут создавать темы. Когда я запускаю свое потребительское приложение для проверки концепции, все темы, которые оно слушает, автоматически создаются на сервере.
Теперь в моем приложении Spring Boot есть настройки, которые предотвращают это. Однако моя цель — обеспечить соблюдение этого правила со стороны сервера Kafka, а не полагаться на отдельные приложения для его соблюдения.
Добавлю, что я еще не настроил аутентификацию или ACL, я все еще на ранней стадии своего пути к Kafka. Так что, если это будет обрабатываться с помощью auth/ACL, это здорово.
Я думаю, что этому должно быть какое-то решение.
Я новичок в Apache Kafka. Одна из вещей, которую я изучаю, — это контроль создания тем на сервере. По сути, я хочу посмотреть, есть ли способ, позволяющий администраторам сервера на 100% контролировать существующие темы, предотвращая создание каких-либо тем любым приложением, подключающимся к серверу.
Я тестирую это с помощью нескольких простых экспериментальных приложений Java/Spring Boot, которые я собрал.
Я установил auto.create.topics.enable=false на своем сервере Kafka. Это успешно предотвращает создание темы производителем Kafka, т. е. KafkaTemplate.send() завершится ошибкой, поскольку тема не существует.
Проблема в том, что потребители, похоже, все еще могут создавать темы. Когда я запускаю свое потребительское приложение для проверки концепции, все темы, которые оно слушает, автоматически создаются на сервере.
Теперь в моем приложении Spring Boot есть настройки, которые предотвращают это. Однако моя цель — обеспечить соблюдение этого правила со стороны сервера Kafka, а не полагаться на отдельные приложения для его соблюдения.
Добавлю, что я еще не настроил аутентификацию или ACL, я все еще на ранней стадии своего пути к Kafka. Так что, если это будет обрабатываться с помощью auth/ACL, это здорово.
Я думаю, что этому должно быть какое-то решение.
