Hi friends, however I suggest you to be aware of the contents of the mail by Manikumar dated October 4 @ 16:44 (see mail list archive): "Deprecated scala consumers/producers are removed from 2.0 release. Old consumer related options are removed from /kafka-consumer-groups.sh tool." ... Best, Marco
-----Messaggio originale----- Da: 赖剑清 [mailto:laijianq...@tp-link.com.cn] Inviato: martedì 23 ottobre 2018 05:55 A: users@kafka.apache.org Oggetto: RE: When Kafka stores group information in zookeeper? Yeah, it works. It all depends on the address of the bootstrap-server: address of zookeeper starts old consumer and kafka-brokers' address with new consumer. Thank you very much! >-----Original Message----- >From: Peter Bukowinski [mailto:pmb...@gmail.com] >Sent: Tuesday, October 23, 2018 11:02 AM >To: users@kafka.apache.org >Subject: Re: When Kafka stores group information in zookeeper? > >It all depends on which type of consumer you are using. If you use an >old >(original) consumer, you must specify one or more zookeepers since >group management info is stored in zookeeper. If you use a new >consumer, group management is handled by the kafka cluster itself so >you must specify one or more brokers in the bootstrap-server list. >Kafka has supported both original and new consumer styles since 0.9. > >In summary, kafka stores consumer group info in zookeeper only if you >are using the old consumer style. It is a consumer-specific setting >entirely independent of topic configuration. > >-- Peter > >> On Oct 22, 2018, at 7:49 PM, 赖剑清 <laijianq...@tp-link.com.cn> wrote: >> >> Hi, Kafka users: >> >> I tried to gain the information of topic-consumer groups using kafka- >consumer-groups.sh. And I found commands below receive different infos: >> ./kafka-consumer-groups.sh --list --zookeeper localhost:2181 >> ./kafka-consumer-groups.sh --list --new-consumer --bootstrap-server >> localhost:9092 >> >> I suppose the first command get data from zookeeper while the second >> one >from the coordinator and my question is: >> When Kafka store group information in zookeeper? When in coordinator? >> Is there any parameter I can specify while creating topic or >> beginning a new >consumer group to make sure these information store in exactly destination? >> >> Version of the broker is 0.9.0.1 and the client is 0.9.0.1 in Java. 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
