Flink检查点已禁用，auto.offset.commit为false

igetnqfo 于 2023-06-04 发布在 Apache

关注(0)|答案(1)|浏览(153)

我们有一个flink应用程序，它从Kafka中消耗记录并转换和生成kafka。
我们使用的是Flink 1.16版本
想要了解下面配置的偏移提交/管理的行为。

Flink 检查点已禁用
auto.commit.enabled = false
offset.reset =最早

来源：https://stackoverflow.com/questions/76379008/flink-checkpoint-disabled-and-auto-offset-commit-is-false

1条答案

按热度按时间

如果您禁用Flink检查点和Kafka Client自动提交，则不会向Kafka提交偏移量。如果你重新启动Flink应用程序，它将从最早的时候读取你启动它的所有内容。

赞(0）回复(0）举报 2023-06-04

相关问题

热门标签

Java query python Node 开发语言 request Util 数据库 Table 后端算法 Logger Message Element Parser

最新问答

xxl-job 安全组扫描到执行器端口服务存在信息泄露漏洞
回答(1) 发布于 3个月前
xxl-job 不能和nacos兼容？
回答(3) 发布于 3个月前
xxl-job 任务执行完后无法结束，日志一直转圈
回答(3) 发布于 3个月前
xxl-job-admin页面上查看调度日志样式问题
回答(1) 发布于 3个月前
xxl-job 参数512字符限制能否去掉
回答(1) 发布于 3个月前