oes not exist.
>
> Regards,
> Anchit
>
>
>
> --
> View this message in context: http://apache-flink-user-
> mailing-list-archive.2336050.n4.nabble.com/Flink-Kafka-
> connector08-not-updating-the-offsets-with-the-zookeeper-tp9469p9498.html
> Sent from the Apache Flink User Mailing List archive. mailing list archive
> at Nabble.com.
>
et results for me.
I think this needs to be corrected in the application: to check and create
"/consumers//owners/" if it does not exist.
Regards,
Anchit
--
View this message in context:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Flink-Kafka-connector08-not-
Hi Anchit,
Can you re-run your job with the debug level for Flink set to DEBUG?
Then, you should see the following log message every time the offset is
committed of Zookeeper:
"Committing offsets to Kafka/ZooKeeper for checkpoint"
Alternatively, can you check whether the offsets are available in
Hi All,
I'm using Flink Kafka connector08. I need to check/monitor the offsets of
the my flink application's kafka consumer.
When running this:
bin/kafka-consumer-groups.sh --zookeeper --describe
--group
I get the message: No topic available for consumer group provided. Why is
the consumer no
