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

Question

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

S.Z*_*ang 5 offset apache-kafka kafka-consumer-api

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

\n\n

\r\n

[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\r\n[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$)\r\nGroup           Topic                          Pid Offset          logSize         Lag             Owner\r\nconsumer-group-1 testtopic                      0   99981           99981           0               none

Run Code Online (Sandbox Code Playgroud)\r\n

\r\n

\n\n

但是当我这样配置时

\n\n

\r\n

ssl.keystore.location=/opt/ssl_key/server.keystore.jks\r\nssl.keystore.password=xdata123\r\nssl.key.password=xdata123\r\nssl.truststore.location=/opt/ssl_key/server.truststore.jks\r\nssl.truststore.password=xdata123\r\n\r\nssl.client.auth=required\r\nssl.enabled.protocols=TLSv1.2,TLSv1.1,TLSv1\r\nssl.keystore.type=JKS\r\nssl.truststore.type=JKS\r\n\r\nsecurity.inter.broker.protocol=SSL\r\nauthorizer.class.name=kafka.security.auth.SimpleAclAuthorizer

Run Code Online (Sandbox Code Playgroud)\r\n

\r\n

\n\n

只需打开 ACL 并使用 kafka-acls.sh 为主题 testtopic 和组 Consumer-group-1\xef\xbc\x8c 添加主体

\n\n

我无法从 kafka-consumer-offset-checker.sh 获取 kafka 偏移量的结果。\nACL 中是否有不同的内容？\n如何在 kafka ACL 模型中获取主题偏移量？

\n