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修改用户权限
本作品采用知识共享署名-非商业性使用 4.0 国际许可协议进行许可。
本文链接:https://www.blog.ycisch.com/archives/753.html