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 w
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.
