为kafka主题配置ACL

Question

我有一个不安全的kafka实例，有两个代理，在我决定为主题配置ACL之前，一切都很好，在ACL配置之后，我的消费者停止了从Kafka那里轮询数据，并且在获取带有相关id的元数据时不断收到警告错误，我的代理属性如下所示：-

listeners=PLAINTEXT://localhost:9092
advertised.listeners=PLAINTEXT://localhost:9092
authorizer.class.name=kafka.security.auth.SimpleAclAuthorizer
allow.everyone.if.no.acl.found=true

我的客户配置如下：

bootstrap.servers=localhost:9092
topic.name=topic-name
group.id=topic-group

我使用下面的命令来配置ACL

bin\windows\kafka-acls.bat  --authorizer-properties zookeeper.connect=localhost:2181 --add --allow-principal User:* Read --allow-host localhost  --consumer --topic topic-name --group topic-group

在完成上述所有配置之后，当我启动使用者时，它就停止接收消息了。有人能指出我错在哪里了吗。提前谢谢。

Answer 1

我们正在成功地使用ACL，但没有使用明文协议。IMHO您应该使用SSL协议，而不是本地主机，使用真正的机器名称。