Конфигурирование ACL для темы kafka

У меня есть незащищенный экземпляр kafka с двумя брокерами, все работает нормально, пока я не решил настроить ACL для тем, после настройки ACL мои потребители прекратили опрос данных из Kafka, и я продолжаю получать предупреждение Ошибка при извлечении метаданных с корреляционным идентификатором, мои свойства брокера выглядит следующим образом: -Конфигурирование ACL для темы kafka

listeners=PLAINTEXT://localhost:9092 
advertised.listeners=PLAINTEXT://localhost:9092 
authorizer.class.name=kafka.security.auth.SimpleAclAuthorizer 
allow.everyone.if.no.acl.found=true

И моя конфигурация клиента выглядит следующим образом: -

bootstrap.servers=localhost:9092 
topic.name=topic-name 
group.id=topic-group

Я использовал следующую команду для настройки ACL

bin\windows\kafka-acls.bat --authorizer-properties zookeeper.connect=localhost:2181 --add --allow-principal User:* Read --allow-host localhost --consumer --topic topic-name --group topic-group

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

источник

2016-07-26 Apollo

Может быть полезно, если вы поместите полную ошибку и ее трассировку стека ... –

Клиент начинает давать предупреждение «Не авторизован для доступа к теме» – Apollo

маленькое примечание: не должно быть «localhost: 2181/kafka «? –

Мы используем ACL успешно, но не с протоколом PLAINTEXT. IMHO вы должны использовать протокол SSL, а вместо localhost - имя реального компьютера.

источник

2018-01-26 09:31:33

Конфигурирование ACL для темы kafka

ответ

Смежные вопросы