如何使用kafka acls？
how to use kafka acls?
我的kafka版本是0.9.0.1，我有两个broker：192.168.1.100, 192.168.1.101，它们使用ssl认证和加密。
我有一个名为 test09 的主题，客户端 ip 是 192.168.1.102
当我使用如下命令行界面添加 acl 时：
bin/kafka-acls.sh --authorizer-properties zookeeper.connect=localhost:2181 --add --deny-principal User:* --deny-host 192.168.1.102 --operation Read --topic test09
来自 192.168.1.102 的消费者仍然可以获取数据。
谁能告诉我如何在 kafka 中使用 ACL？
我相信您错过了在 Server.properties
中添加以下 属性
authorizer.class.name=kafka.security.auth.SimpleAclAuthorizer
-- 添加此行将使 ACL 能够通过 SimpleAclAuthorizer 工作。 -- Kafka 默认自带参数 authorizer.class.name.
定义的 kafka.security.auth.SimpleAclAuthorizer
您可以尝试以下设置，这可能会给出完整的想法。
我的kafka版本是0.9.0.1，我有两个broker：192.168.1.100, 192.168.1.101，它们使用ssl认证和加密。
我有一个名为 test09 的主题，客户端 ip 是 192.168.1.102
当我使用如下命令行界面添加 acl 时：
bin/kafka-acls.sh --authorizer-properties zookeeper.connect=localhost:2181 --add --deny-principal User:* --deny-host 192.168.1.102 --operation Read --topic test09
来自 192.168.1.102 的消费者仍然可以获取数据。
谁能告诉我如何在 kafka 中使用 ACL？
我相信您错过了在 Server.properties
中添加以下 属性authorizer.class.name=kafka.security.auth.SimpleAclAuthorizer
-- 添加此行将使 ACL 能够通过 SimpleAclAuthorizer 工作。 -- Kafka 默认自带参数 authorizer.class.name.
kafka.security.auth.SimpleAclAuthorizer
您可以尝试以下设置，这可能会给出完整的想法。