Get consumer group offset

classic Classic list List threaded Threaded
2 messages Options
qq
Reply | Threaded
Open this post in threaded view
|

Get consumer group offset

qq
Hi all,

   I use Kafka 0.10.0, Flink 1.9.0, why I can’t get flink consumer10 group which I had configured.  And I use KafkaConsumer not with Flink to consumer the same topic, I can get the consumer group metadata. Thanks.

Kafka/bin/kafka-run-class kafka.admin.ConsumerGroupCommand --bootstrap-server t4:9092,t5:9092,t6:9092 --new-consumer --list|grep consumer_group_1


  AlexFu
Reply | Threaded
Open this post in threaded view
|

Re: Get consumer group offset

Arvid Heise-3
Hi Alex,

seems like your message got lost during christmas.

I don't completely understand the question. Do you mean that Flink does not pick up the consumer group anymore?

Btw out of curiosity, why are you still running Kafka 0.10? We are thinking about dropping support for older Kafka versions as we expect most users to use newer versions now.

Best,

Arvid

On Tue, Dec 24, 2019 at 10:09 AM qq <[hidden email]> wrote:
Hi all,

   I use Kafka 0.10.0, Flink 1.9.0, why I can’t get flink consumer10 group which I had configured.  And I use KafkaConsumer not with Flink to consumer the same topic, I can get the consumer group metadata. Thanks.

Kafka/bin/kafka-run-class kafka.admin.ConsumerGroupCommand --bootstrap-server t4:9092,t5:9092,t6:9092 --new-consumer --list|grep consumer_group_1


  AlexFu