kafka增加安全配置报错问题

问题遇到的现象和发生背景

按照教程,给kafka增加安全配置,但是在第8步,启动kafka 的时候会报错误。
ClusterAuthorizationException: Request Request() is not authorized.

img


然后,在发送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