У меня есть незащищенный экземпляр kafka с 2 брокерами, все работало нормально, пока я не решил настроить ACL для тем, после настройки 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
После всех вышеперечисленных настроек, когда я запускаю потребителя, он перестал получать сообщения. Может кто-нибудь указать, где я ошибаюсь. Заранее спасибо.
