Unable to retrieve Kafka consumer group offsets

[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/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

[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 <[hidden email]> 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

[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_NqYz_w@...%3E

On Fri, Nov 8, 2019 at 5:18 AM Till Rohrmann <[hidden email]> 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 <[hidden email]> 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