flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Mojes <mojeskamlap...@ymail.com>
Subject Re: Flink kafka group question
Date Fri, 05 Aug 2016 12:35:18 GMT
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.

Mime
View raw message