MENU
// //

Kafak SASL_SSL配置多用户ACL校验

February 12, 2025 • 学习生涯,技术分享

Kafka SASL_SSL模式添加多用户

1.修改kafka_server_jass.conf文件

#添加对应的用户与密码
KafkaServer {
     org.apache.kafka.common.security.plain.PlainLoginModule required
     username="admin"
     password="123456"
     user_admin="123456"
     user_user1="123123"
     user_user2="123456789";
 };

2.修改kafka server.properties配置

添加如下配置 开启ACL认证 请确保这三个都存在

authorizer.class.name=kafka.security.authorizer.AclAuthorizer
allow.everyone.if.no.acl.found=false
super.users=User:admin

3.修改用户权限

3.1 使用命令修改用户的权限

注意修改命令中的ip port belongMine1与本身环境对应 如有集群 请注意bootstrap-server的配置

集群情况下 bootstarp-server需用逗号隔开ip:port,ip1:port1

  • 给用户添加group的权限)

./bin/kafka-acls.sh --bootstrap-server ip:port --add --allow-principal User:user1--group kafka-group --operation All --command-config /root/admin.conf

  • 给用户添加topic的权限

./bin/kafka-acls.sh --bootstrap-server ip:port --topic '*' --add --allow-principal User:user1 --operation All --command-config /root/admin.conf

3.2 使用KafkaTools修改用户权限

kafka