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
