Я пытаюсь включить имя пользователя и пароль SASL для кластера Kafka без ssl.Я следовал инструкциям этого Stackoverflow:
Аутентификация Kafka SASL zookeeper
Аутентификация SASL, похоже, работает для брокеров Kafka.потребители и производители должны проходить аутентификацию перед тем, как писать или читать какую-либо тему.Пока все хорошо.
Проблема в создании и удалении тем на кафке.например, когда я пытаюсь использовать следующую команду:
~/kafka/bin/kafka-topics.sh --list --zookeeper 10.x.y.z:2181
Я могу перечислить все темы в кластере kafka и создать или удалить любую тему без какой-либо аутентификации.
Iпопытался выполнить следующие шаги:
Аутентификация и авторизация суперпользователя
, но, похоже, ничего не работает.
Любая помощь в этом вопросе действительно ценится.
Спасибо, С уважением, Firas Khasawneh