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 <soumey...@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. >
