如何使用 Kafka SSL&ACL 获取 kafka 偏移量答案

【问题标题】：How to get kafka offset with Kafka SSL&ACL如何使用 Kafka SSL&ACL 获取 kafka 偏移量
【发布时间】：2017-01-10 09:00:13
【问题描述】：

我有一个带有 SSL&ACL 的 kafka 集群当我关闭 ACL 时，我可以获得来自 kafka-consumer-offset-checker.sh 的偏移量

[root@node128 kafka_2.10-0.10.0.0]# bin/kafka-consumer-offset-checker.sh --zookeeper localhost:2181/kafka-test --group consumer-group-1 --topic testtopic
[2016-09-02 14:03:51,722] WARN WARNING: ConsumerOffsetChecker is deprecated and will be dropped in releases following 0.9.0. Use ConsumerGroupCommand instead. (kafka.tools.ConsumerOffsetChecker$)
Group           Topic                          Pid Offset          logSize         Lag             Owner
consumer-group-1 testtopic                      0   99981           99981           0               none

但是当我这样配置时

ssl.keystore.location=/opt/ssl_key/server.keystore.jks
ssl.keystore.password=xdata123
ssl.key.password=xdata123
ssl.truststore.location=/opt/ssl_key/server.truststore.jks
ssl.truststore.password=xdata123

ssl.client.auth=required
ssl.enabled.protocols=TLSv1.2,TLSv1.1,TLSv1
ssl.keystore.type=JKS
ssl.truststore.type=JKS

security.inter.broker.protocol=SSL
authorizer.class.name=kafka.security.auth.SimpleAclAuthorizer

只需开启 ACL 并使用 kafka-acls.sh 为主题 testtopic 和组 consumer-group-1 添加主体，

我无法从 kafka-consumer-offset-checker.sh 获得 kafka 偏移量的结果。 ACL 中有什么不同之处吗？如何在 kafka ACL 模型中获取主题偏移量？

【问题讨论】：

标签： apache-kafka offset kafka-consumer-api

【解决方案1】：

每个网站：https://docs.confluent.io/platform/current/kafka/authorization.html

您需要一个具有以下配置的 acl：

阅读小组。还要确保您正确设置模式

【讨论】：