flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Janardhan Reddy <janardhan.re...@olacabs.com>
Subject Flink Kafka Consumer Behaviour
Date Tue, 02 Aug 2016 11:26:39 GMT
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

Mime
View raw message