Re: Unable to retrieve Kafka consumer group offsets
Thanks Till, The link the the thread is here: http://mail-archives.apache.org/mod_mbox/flink-user/201702.mbox/%3ccagr9p8cekzvx3fxqi363o3tbd37nuppe7l_+c7+kx_z_nqy...@mail.gmail.com%3E On Fri, Nov 8, 2019 at 5:18 AM Till Rohrmann wrote: > Hi Harrison, > > which mailing list thread are you referring to exactly? I've pulled in > Becket who might be able to tell you more about the Kafka connector. > > Cheers, > Till > > On Thu, Nov 7, 2019 at 11:11 PM Harrison Xu wrote: > >> I am using Flink 1.9.0 and KafkaConsumer010 (Kafka 0.10.1.1). Attempting >> to retrieve the offset lag of Flink kafka consumers results in the below >> error. I saw a separate thread about this in the mailing list in 2017 - is >> this not fixed? Are there workarounds? >> >> >> > $ /work/kafka_2.11-0.10.1.1/bin/kafka-consumer-groups.sh >> > --bootstrap-server localhost:9092 --group test --describe >> > Error while executing consumer group command Group test with protocol type >> > '' is not a valid consumer group >> >> >> >> >>
Re: Unable to retrieve Kafka consumer group offsets
Hi Harrison, which mailing list thread are you referring to exactly? I've pulled in Becket who might be able to tell you more about the Kafka connector. Cheers, Till On Thu, Nov 7, 2019 at 11:11 PM Harrison Xu wrote: > I am using Flink 1.9.0 and KafkaConsumer010 (Kafka 0.10.1.1). Attempting > to retrieve the offset lag of Flink kafka consumers results in the below > error. I saw a separate thread about this in the mailing list in 2017 - is > this not fixed? Are there workarounds? > > > > $ /work/kafka_2.11-0.10.1.1/bin/kafka-consumer-groups.sh > > --bootstrap-server localhost:9092 --group test --describe > > Error while executing consumer group command Group test with protocol type > > '' is not a valid consumer group > > > > >
Unable to retrieve Kafka consumer group offsets
I am using Flink 1.9.0 and KafkaConsumer010 (Kafka 0.10.1.1). Attempting to retrieve the offset lag of Flink kafka consumers results in the below error. I saw a separate thread about this in the mailing list in 2017 - is this not fixed? Are there workarounds? > $ /work/kafka_2.11-0.10.1.1/bin/kafka-consumer-groups.sh > --bootstrap-server localhost:9092 --group test --describe > Error while executing consumer group command Group test with protocol type > '' is not a valid consumer group
