kafka提供kafka-acls.bat,针对不同的topic,可设置针对不同用户的读写权限等
https://kafka.apache.org/25/documentation.html#security_sasl
TopicAuthorizationException
原因1:topic不存在
原因2:如权限不对,则会提示 org.apache.kafka.common.errors.TopicAuthorizationException: Not authorized to access topics: [xxx]

kafka日志

查看当前的ACL限制

结果样例:

增加授权:开放ACL授权
