Sorry, I think you are actually asking for the largest offset in the Kafka
source, which makes it setProperty("auto.offset.reset", "largest").
> Am 05.08.2016 um 14:44 schrieb Stefan Richter <[email protected]>:
>
> Hi,
>
> I think passing properties with setProperty("auto.offset.reset", "smallest“)
> to the Kafka consumer should do what you want.
>
> Best,
> Stefan
>
>
>> Am 05.08.2016 um 14:36 schrieb Mao, Wei <[email protected]
>> <mailto:[email protected]>>:
>>
>> 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
>
