Hey, Are You completely sure you mean *auto.offset.reset ?? *False is not valid setting for that AFAIK.
Best, Dom. czw., 26 mar 2020 o 08:38 Jim Chen <chenshuai19950...@gmail.com> napisał(a): > Thanks! > > I made a mistake. I forget to set the auto.offset.reset=false. It's my > fault. > > Dominik Wosiński <wos...@gmail.com> 于2020年3月25日周三 下午6:49写道： > >> Hi Jim, >> Well, *auto.offset.reset *is only used when there is no offset saved for >> this *group.id <http://group.id>* in Kafka. So, if You want to read the >> data from the latest record (and by latest I mean the newest here) You >> should assign the *group.id <http://group.id>* that was not previously >> used and then FlinkKafkaConsumer should automatically fetch the last offset >> and start reading from that place. >> >> >> Best Regards, >> Dom. >> >> śr., 25 mar 2020 o 11:19 Jim Chen <chenshuai19950...@gmail.com> >> napisał(a): >> >>> Hi, All >>> I use flink-connector-kafka-0.11 consume the Kafka0.11. In >>> KafkaConsumer params, i set the group.id and auto.offset.reset. In the >>> Flink1.10, set the kafkaConsumer.setStartFromGroupOffsets(); >>> Then, i restart the application, found the offset is not from the last >>> position. Any one know where is wrong? HELP! >>> >>
