Hi all,
I installed kafka_2.11-2.0.0 tarball on a CentOS server :
[kafka@oxelkk-bo-1:~] $ uname -a
Linux oxelkk-bo-1 3.10.0-862.11.6.el7.x86_64 #1 SMP Tue Aug 14 21:49:04 UTC 
2018 x86_64 x86_64 x86_64 GNU/Linux
[kafka@oxelkk-bo-1:~] $

equipped with this JVM:
[kafka@oxelkk-bo-1:~] $ java -version
java version "1.8.0_77"
Java(TM) SE Runtime Environment (build 1.8.0_77-b03)
Java HotSpot(TM) 64-Bit Server VM (build 25.77-b03, mixed mode)
[kafka@oxelkk-bo-1:~] $

I have a strange behavior of the utility bin/kafka-consumer-groups.sh when it 
is called with --zookeeper option, like:

[kafka@oxelkk-bo-1:~] $ 
/store1/elk/run/kafka_2.11-2.0.0/bin/kafka-consumer-groups.sh --zookeeper 
oxelkk-bo-1.iol.local:2181 --list
Exception in thread "main" joptsimple.UnrecognizedOptionException: zookeeper is 
not a recognized option
        at 
joptsimple.OptionException.unrecognizedOption(OptionException.java:108)
        at joptsimple.OptionParser.handleLongOptionToken(OptionParser.java:510)
        at 
joptsimple.OptionParserState$2.handleArgument(OptionParserState.java:56)
        at joptsimple.OptionParser.parse(OptionParser.java:396)
        at 
kafka.admin.ConsumerGroupCommand$ConsumerGroupCommandOptions.<init>(ConsumerGroupCommand.scala:725)
        at kafka.admin.ConsumerGroupCommand$.main(ConsumerGroupCommand.scala:42)
        at kafka.admin.ConsumerGroupCommand.main(ConsumerGroupCommand.scala)
[kafka@oxelkk-bo-1:~] $

Whilst if I use (just for a test) the same utility coming with 
kafka_2.11-0.11.0.0, I have the expected response (the groups are related to 
two Druid Tranquility tasks):

[kafka@oxelkk-bo-1:~] $ 
/store1/elk/run/kafka_2.11-0.11.0.0/bin/kafka-consumer-groups.sh --zookeeper 
oxelkk-bo-1.iol.local:2181 --list
Note: This will only show information about consumers that use ZooKeeper (not 
those using the Java consumer API).

tranquility-kafka-proxy
tranquility-kafka-ssoeven
[kafka@oxelkk-bo-1:~] $

I noticed that the documentation for Kafka 2.0.0 at: 
https://kafka.apache.org/documentation/#basic_ops_consumer_lag states:

This tool also works with ZooKeeper-based consumers:
bin/kafka-consumer-groups.sh --zookeeper localhost:2181 --describe --group 
my-group

Do you have any hint on this behavior?
Thank you very much,

Marco Spadoni
Italiaonline S.p.A.



This email and any files transmitted with it are confidential and intended 
solely for the use of the individual or entity to whom they are addressed. If 
you have received this email in error please notify postmas...@italiaonline.it .
www.italiaonline.it

Reply via email to