flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Anchit Jatana <development.anc...@gmail.com>
Subject Flink Kafka connector08 not updating the offsets with the zookeeper
Date Wed, 12 Oct 2016 00:35:35 GMT
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

Mime
View raw message