ACL相关命令

ACL相关命令

查看当前的acl列表:

$ kafka-acls --authorizer-properties zookeeper.connect=$ZOOKEEPER --list

image-20220117084826447

查看具体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