How to get kafka offset with Kafka SSL&ACL -


i have kafka cluster ssl&acl when trun off acl,i can offset form 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 deprecated , 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

but when configure

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

just trun on acl , use kafka-acls.sh add principal topic testtopic , group consumer-group-1,

i cannot result of kafka offset kafka-consumer-offset-checker.sh. there deferent in acl? how can topics` offset in kafka acl model?


Comments