apache-kafka - 如何使用kafka acls？

Question

我的 kafka 版本是 0.9.0.1，我有两个代理: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 吗？

Answer 1

我相信您没有在 Server.properties 中添加以下属性

authorizer.class.name=kafka.security.auth.SimpleAclAuthorizer

-- 添加此行将使 ACL 能够通过 SimpleAclAuthorizer 工作。 -- 默认情况下，Kafka 带有 kafka.security.auth.SimpleAclAuthorizer由参数 authorizer.class.name 定义.

您可以尝试以下设置，这可能会给出完整的想法。

https://github.com/Symantec/kafka-security-0.9