问题遇到的现象和发生背景
按照教程,给kafka增加安全配置,但是在第8步,启动kafka 的时候会报错误。
ClusterAuthorizationException: Request Request() is not authorized.
然后,在发送kafka消息的时候就会报 TOPIC_AUTHORIZATION_FAILED 错误。
请问知道是哪里漏了么?
kafka-acls.bat --authorizer-properties zookeeper.connect=localhost:2181 --topic * --add --allow-principal User:kafka --operation all --group "*"
这句是否有问题导致的?
用代码块功能插入代码,请勿粘贴截图
https://www.bilibili.com/read/cv11773508?spm_id_from=333.999.0.0
附件:
链接:https://pan.baidu.com/s/1uGmM77B4dNJdtUPPScPnfw?pwd=kzaj
提取码:kzaj