bhu
>
>
>
> --
> View this message in context: http://apache-flink-user-
> mailing-list-archive.2336050.n4.nabble.com/Flink-kafka-
> group-question-tp8185p8374.html
> Sent from the Apache Flink User Mailing List archive. mailing list archive
> at Nabble.com.
>
ing is enabled, the auto commit in kafka is disabled, I
am still trying to find out how to get a external view from the kafka offset
utilities in this scenario.
Thanks,
Prabhu
--
View this message in context:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Flink-kafka-gr
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-gr
Hi,
1. What Flink Kafka connector version are you using?
2. How is your non-Flink consumer fetching data from the topic? Is it using
the old SimpleConsumer, old High-Level Consumer, or the new consumer API?
3. If you are using the new consumer API, are you using
"consumer.assign(…)" or "consumer.s
Hi,
I am using kafka in couple of programs including flink and I am quite
confused that how group.id parameter work in flink with kafka comsumer.I
have 2 consumers (one in side flink, one outside) running on the same
topic and same group.id. From my inpection, they work isolately:If
I send one
