如何使用KafkaACL？

hxzsmxv2 于 2021-06-07 发布在 Kafka

关注(0)|答案(1)|浏览(381)

我的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吗？

apache-kafka ACL

来源：https://stackoverflow.com/questions/35769728/how-to-use-kafka-acls

1条答案

按热度按时间

fjnneemd1#

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

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

--添加此行将使acl能够通过SimpleClauthorizer工作。-默认情况下，Kafka附带 kafka.security.auth.SimpleAclAuthorizer 由参数定义 authorizer.class.name .
您可以尝试下面的设置，这可能会给出完整的想法。
https://github.com/symantec/kafka-security-0.9

赞(0）回复(0）举报 2021-06-07

我来回答

如何使用KafkaACL？

1条答案

相关问题

热门标签

最新问答