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時,需要注意以下幾點: