Apache Kafka中的ACL(Access Control List)用于控制用户对主题的访问权限。ACL可以配置在broker级别或者主题级别,以实现细粒度的访问控制。
在Kafka中配置ACL的步骤如下:
例如:
{
"allow": true,
"principal": "User:alice",
"resource": "Topic:test-topic",
"operation": "Read"
}
例如,添加ACL:
bin/kafka-acls.sh --authorizer-properties zookeeper.connect=localhost:2181 --add --allow-principal User:alice --operation Read --topic test-topic
例如,在server.properties中添加如下配置:
authorizer.class.name=kafka.security.auth.SimpleAclAuthorizer
在配置ACL时,需要注意以下几点: