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 <h...@quora.com> 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 > > > > >
