apache-kafka - 代理复制错误 "Not authorized to access topics: [Topic authorization failed.] "

Question

我有三个 Kafka 经纪人( kafka_2.11-0.10.0.0 )每个经纪人的安全配置如下，

listeners=PLAINTEXT://xxxx:9093,SASL_PLAINTEXT://xxxx:10093
advertised.listeners=PLAINTEXT://xxxx:9093,SASL_PLAINTEXT://xxxx:10093
security.inter.broker.protocol=PLAINTEXT
sasl.enabled.mechanisms=PLAIN
sasl.mechanism.inter.broker.protocol=PLAIN
authorizer.class.name=kafka.security.auth.SimpleAclAuthorizer
allow.everyone.if.no.acl.found=true
super.users=User:admin

kafka_server_jaas.conf 也配置了 admin 用户。

KafkaServer {
        org.apache.kafka.common.security.plain.PlainLoginModule required
        username="admin"
        password="welcome1"
        user_guest="welcome1";
};

当我连接使用 PLAINTEXT 监听器并生成和使用消息时，一切正常。

但是当我尝试将 ACL 添加到某个主题时，集群将输出如下错误消息:

bin/kafka-acls.sh --authorizer-properties zookeeper.connect=xxxx:2181/kafka10  --add --allow-principal User:guest --producer --topic page_visits_10k  

经纪人输出

[2016-05-31 10:49:57,497] ERROR [ReplicaFetcherThread-0-2], Error for partition [page_visits_10k,1] to broker 2:org.apache.kafka.common.errors.TopicAuthorizationException: Not authorized to access topics: [Topic authorization failed.] (kafka.server.ReplicaFetcherThread)
[2016-05-31 10:49:59,003] ERROR [ReplicaFetcherThread-0-2], Error for partition [page_visits_10k,1] to broker 2:org.apache.kafka.common.errors.TopicAuthorizationException: Not authorized to access topics: [Topic authorization failed.] (kafka.server.ReplicaFetcherThread)

错误输出看起来像代理间复制错误，感谢您的帮助。

Answer 1

我在使用 Kafka v.0.10 中的 ACL 时遇到了类似的问题。我找到了 this讨论很有帮助。特别是启用授权日志以检查请求的传入用户名是什么以及它在您的 ACL 中指定了什么。

可以通过修改 config 文件夹中的 log4j.properties 来启用授权日志。在 log4j.properties 文件中，更改 WARN至 DEBUG并重新启动 kafka 服务器。

log4j.logger.kafka.authorizer.logger=DEBUG, authorizerAppender

这帮助我整理了我的问题。希望有帮助。

PS:生成的授权日志会很长，占用大量空间。因此，请记住在完成调试后将其关闭。