【Kafka】安全ACL/SASL

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授权  

  

原文地址:https://www.cnblogs.com/clarino/p/15272706.html