flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Mao, Wei" <wei....@intel.com>
Subject How to get latest offsets with FlinkKafkaConsumer
Date Fri, 05 Aug 2016 12:36:01 GMT
I am doing some performance tests with Flink (1.0.3 )+ Kafka (0.8.2.2). And I noticed that
when I restarted my Flink application, it reads records starting from the latest offset that
I consumed last time, but not the latest offsets of that topic in Kafka.

So Is there any way to make it read from last offsets of broker/MyTopic instead of consumer/MyTopic
in Flink?

Thanks,
William


Mime
View raw message