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
Post a Comment