GroupOffsetReset functionality

[Sangbida Dutta <so...@gmail.com>]

Hi ,

Currently I am using flink 1.13 . To configure kafka consumers start
position i am using  setStartFromGroupOffsets() method of
FlinkKafkaConsumer.
if Group offset is set, it should read committed, but if they are not found
then how will it work ?

Any help would be appreciated.

Thanks.

Re: GroupOffsetReset functionality

[Caizhi Weng <ts...@gmail.com>]

Hi!

Sorry that I can't quite understand this question. By "it should read
committed" do you mean something about the state of Kafka source? If yes
the document [1] states that

Set setStartFromGroupOffsets(true) on the consumer so that we get read
> offsets from Kafka. This will only take effect when there is no read offset
> in Flink state...
>

 [1]
https://nightlies.apache.org/flink/flink-docs-master/docs/connectors/datastream/kafka/#upgrading-to-the-latest-connector-version

Sangbida Dutta <so...@gmail.com> 于2021年11月22日周一 下午3:30写道：

> Hi ,
>
> Currently I am using flink 1.13 . To configure kafka consumers start
> position i am using  setStartFromGroupOffsets() method of
> FlinkKafkaConsumer.
> if Group offset is set, it should read committed, but if they are not
> found then how will it work ?
>
> Any help would be appreciated.
>
> Thanks.
>