apache-kafka - 使用 KafkaConsumer 的 listTopics() 时误报 kafka-authorizer.log

Question

使用 listTopics() method from KafkaConsumer 时对于集群中用户没有授权的每个主题，SimpleAuthorizer.scala 在 kafka-authorizer.log 中创建如下日志行:

INFO Principal = User:user is Denied Operation = Describe from host = ip on resource = Topic:LITERAL:topicName (kafka.authorizer.logger)

有没有一种简单的方法可以从 listTopics() 中删除这些“误报”日志，同时又不会失去访问“外部”主题的真正尝试？背景:在一个大型共享集群中来自不同独立开发团队的许多主题(一个团队只有一个“描述”ACL 条目用于其自己的主题)，这会导致大量安全日志，当使用 listTopics() 时，没有“黑客”的意图.

Answer 1

向所有用户授予 DESCRIBE acl 操作怎么样？像这样:

/bin/kafka-acls --authorizer kafka.security.auth.SimpleAclAuthorizer --authorizer-properties zookeeper.connect=zoo-1:2181 --allow-principal User:\* --topic \* --operation describe --add
/bin/kafka-acls --authorizer kafka.security.auth.SimpleAclAuthorizer --authorizer-properties zookeeper.connect=zoo-1:2181 --allow-principal User:\* --group \* --operation describe --add
/bin/kafka-acls --authorizer kafka.security.auth.SimpleAclAuthorizer --authorizer-properties zookeeper.connect=zoo-1:2181 --allow-principal User:\* --cluster \* --operation describe --add