Hi All,

I'm using Flink Kafka connector08. I need to check/monitor the offsets of
the my flink application's kafka consumer.

When running this:

bin/kafka-consumer-groups.sh --zookeeper <zookeeper-url:port> --describe
--group <group-id>

I get the message: No topic available for consumer group provided. Why is
the consumer not updating the offsets with the zookeeper ?

PS: I have enabled checkpointing. Is there any configuration that I'm
missing or is this some sort of a bug?

Using Flink version 1.1.2

Thank you

Regards,
Anchit

Reply via email to