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
