爲kafka主題配置ACL

我有一個帶有2個代理的不安全kafka實例，一切正常，直到我決定爲主題配置ACL，配置ACL後，消費者停止輪詢來自Kafka的數據，並且不斷收到警告獲取元數據時出錯與相關ID，我的經紀人性質的樣子如下： -爲kafka主題配置ACL

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協議。恕我直言，你應該使用SSL協議，而不是本地主機使用真正的機器名稱。

來源

2018-01-26 09:31:33

爲kafka主題配置ACL

回答

相關問題