Hi Janardhan,
Flink should commit the current offsets to Zookeeper whenever a checkpoint
has been completed. In case that you disabled checkpointing, then the
offsets will be periodically committed to ZooKeeper. The default value is
60s.
Could it be that there wasn't yet a completed checkpoint? Which version of
Flink are you using?
Cheers,
Till
On Tue, Aug 2, 2016 at 7:26 PM, Janardhan Reddy <janardhan.re...@olacabs.com
> wrote:
> Hi,
>
> When the run the following command i am getting that no topic is available
> for that consumer group. i am suing
> flink-connector-kafka-0.8_${scala.version}(2.11).
>
> ./bin/kafka-consumer-groups.sh --zookeeper <> --group <> --describe
>
> No topic available for consumer group provided
>
>
> Does the kafka consumer commit offset to the broker always ? Do we need to
> enable checkpointing for the offsets to be committed ?
>
>
> Thanks
>
