查看当前的acl列表:
$ kafka-acls --authorizer-properties zookeeper.connect=$ZOOKEEPER --list
查看具体topic的ACL列表:
$ kafka-acls --authorizer-properties zookeeper.connect=$ZOOKEEPER --list --topic topic-name
添加ACL:
kafka-acls --authorizer-properties zookeeper.connect=$ZOOKEEPER \
--add --allow-principal "User:CN=NOT-A-USER" \
--operation Read \
--group=* \
--topic secure-topic
删除ACL:
kafka-acls --authorizer-properties zookeeper.connect=$ZOOKEEPER \
--add --allow-principal "User:mskuser" \
--operation Read --operation Write \
--group=* \
--topic secure-topic