我们需要两样东西。
（除了对客户机服务器角色和身份验证与授权的安全性有很好的理解！）
首先将用户添加到sasl配置中。为经纪人和客户。
（解决认证部分）
第二个是将新用户作为超级用户添加到kafka broker server.properties。
（解决授权部分）
详细信息（仅以一个条目为例）：
代理端的jaas配置

KafkaServer {
     org.apache.kafka.common.security.plain.PlainLoginModule required
     user_testuser="testuser_password";
 };

jaas配置“客户端”

security.protocol=SASL_PLAINTEXT
sasl.mechanism=PLAIN
sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required \
username=\"testuser\" password=\"testuser_password\";

服务器属性

super.users=User:testuser

现在当我跑的时候
（kafka\u tools\u jaas.conf包含客户端的jaas配置）它工作得很好。

kafka-consumer-groups --describe --group testavroCons --bootstrap-server server:port --command-config /tmp/kafka_tools_jaas.conf

对于用户 u 能够描述一个群体 g 从主题中消耗 t 这些ACL权限是必需的：

bin/kafka-acls.sh --authorizer kafka.security.auth.SimpleAclAuthorizer --authorizer-properties zookeeper.connect=localhost:2181 --add --allow-principal User:u --operation Describe --group g
bin/kafka-acls.sh --authorizer kafka.security.auth.SimpleAclAuthorizer --authorizer-properties zookeeper.connect=localhost:2181 --add --allow-principal User:u --operation Describe --topic t

参考