4.7.3. 添加 ACL 规则

流程

1. 使用 --add 选项运行 kafka-acls.sh。

   示例：

   • 允许 user1 和 user2 使用 MyConsumerGroup 消费者组从 myTopic 读取。

     bin/kafka-acls.sh --authorizer-properties zookeeper.connect=zoo1.my-domain.com:2181 --add --operation Read --topic myTopic --allow-principal User:user1 --allow-principal User:user2
     
     bin/kafka-acls.sh --authorizer-properties zookeeper.connect=zoo1.my-domain.com:2181 --add --operation Describe --topic myTopic --allow-principal User:user1 --allow-principal User:user2
     
     bin/kafka-acls.sh --authorizer-properties zookeeper.connect=zoo1.my-domain.com:2181 --add --operation Read --operation Describe --group MyConsumerGroup --allow-principal User:user1 --allow-principal User:user2

     Copy to Clipboard Toggle word wrap

   • 拒绝从 IP 地址主机 127.0.0.1 读取 myTopic 的 user1 访问。

     bin/kafka-acls.sh --authorizer-properties zookeeper.connect=zoo1.my-domain.com:2181 --add --operation Describe --operation Read --topic myTopic --group MyConsumerGroup --deny-principal User:user1 --deny-host 127.0.0.1

     Copy to Clipboard Toggle word wrap

   • 使用 MyConsumerGroup 添加 user1 作为 myTopic 的使用者。

     bin/kafka-acls.sh --authorizer-properties zookeeper.connect=zoo1.my-domain.com:2181 --add --consumer --topic myTopic --group MyConsumerGroup --allow-principal User:user1

     Copy to Clipboard Toggle word wrap