Hi Gordon, I am consuming the messages from kafka with *FlinkKafkaConsumer09 *and I have also specified the group.id. I have *enabled checkpointing*, and below configs *auto.commit.enable=true auto.offset.reset=earliest.*
>From your post I could understand that group.id is not much useful as far as offset monitoring is concerned. Is there any way that I can get the info on current offset of consumer, current offset of topic and the lag of offset. Thanks, Mojes -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Flink-kafka-group-question-tp8185p8343.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.
