Hi, 1. Yes, the kafka source will use the Kafka committed offset for the group id to start the job.
2. No, the auto.offset.reset <https://kafka.apache.org/documentation/#consumerconfigs_auto.offset.reset> is from Kafka consumer config, which defines what to do when there is no initial offset in Kafka or if the current offset does not exist any more on the server. If the offset exists on the server, the consumer will still start from the committed offset. ps: If you enabled checkpointing, there is no need to enable enable.auto.commit. The offset will be committed to Kafka when checkpoints complete, which is the default behavior. Vishal Santoshi <vishal.santo...@gmail.com> 于2021年12月4日周六 02:11写道： > Hello folks, > > 2 questions > 1. If we have enabled enable.auto.commit and enabled checkpointing and we > restart a flink application ( without checkpoint or savepoint ) , would the > kafka consumer start consuming from the last offset committed to kafka. > > 2. What if in the above scenario, we have "auto.offset.reset" set to > "latest". ? Would that ignore the consumer group offset in kafka ? > > > Regards. >
