英文:
Flink checkpoint disabled and auto.offset.commit is false
问题
我们有一个使用Flink的应用程序，从Kafka消费记录，然后进行转换并生产到Kafka。
我们正在使用Flink版本1.16。
希望了解以下配置下的偏移提交/管理行为。
- 禁用了Flink的检查点
- auto.commit.enabled = false
- offset.reset = earliest
英文:
We have flink app which consumes record from kafka and transform and produce to kafka.
We are using Flink version 1.16
Want to understand the behaviour of offset commit/management with below configuration .
- flink checkpoint disabled
- auto.commit.enabled = false
- offset.reset = earliest
答案1
得分: 0
如果您禁用了Flink的检查点和Kafka客户端的自动提交，将不会提交任何偏移量到Kafka。如果您重新启动您的Flink应用程序，它将从最早的偏移量开始读取所有数据。
英文:
If you disable both Flink checkpoints and Kafka Client auto committing, no offsets will be committed to Kafka. If you restart your Flink application, it will read from earliest everything you're starting it.
通过集体智慧和协作来改善编程学习和解决问题的方式。致力于成为全球开发者共同参与的知识库，让每个人都能够通过互相帮助和分享经验来进步。
评论