Re: Unable to retrieve Kafka consumer group offsets

2019-11-08 Thread Harrison Xu
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 referrin

Re: Unable to retrieve Kafka consumer group offsets

2019-11-08 Thread Till Rohrmann
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 >

Unable to retrieve Kafka consumer group offsets

2019-11-07 Thread Harrison Xu
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/kaf