如果我已将自动提交设置为true，并且

Question

我正在阅读https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/connectors/datastream/kafka/#kafka-消费者补偿提交行为配置

它说：

启用检查点：如果启用了检查点，Flink Kafka使用者将在检查点完成时提交存储在检查点状态中的偏移量。这确保了Kafka代理中提交的偏移量与检查点状态中的偏移量一致。用户可以通过在使用者上调用setCommitofSetsonCheckpoints（布尔）方法来选择禁用或启用偏移量提交（默认情况下，行为为true）。请注意，在此场景中，将完全忽略属性中的自动定期偏移提交设置。

如果我以10秒的间隔启用检查点，我还将CommitofSetsonCheckpoints设置为true，并将enable设置为enable。汽车提交=true和自动。犯罪间隔在Kafka消费者财产中，ms=5000。

那么，偏移量提交的行为是什么？是否每10秒提交3次偏移？执行检查点时从flink执行一次，从Kafka消费者的自动提交执行两次？

Answer 1

enable.auto.commit：自动偏移提交，这个值的配置不是最终的偏移提交模式，需要考虑用户是否启用了检查点，将在下面的源代码分析中解释

消费者SetCommitofSetsonCheckpoints（true）​ 说明：设置完检查点后，提交偏移量，即oncheckpoint模式。默认情况下，该值为true。此参数将影响抵销的提交方式。下面的源代码将对其进行分析

因此，根据您所述的报价，并进一步查看互联网，Flink消费者将忽略汽车。提交配置启用检查点后，偏移提交行为将由使用者定义。SetCommitofSetsonCheckpoints已定义（默认情况下为true）

https://www.programmersought.com/article/84744879064/

来自Flink文档

禁用检查点：如果禁用检查点，Flink Kafka使用者将依赖内部使用的Kafka客户端的自动定期偏移提交功能。因此，要禁用或启用偏移量提交，只需设置enable。汽车提交/自动。犯罪间隔ms键到所提供的属性配置中的适当值。

启用检查点：如果启用了检查点，Flink Kafka使用者将在检查点完成时提交存储在检查点状态中的偏移量。这确保了Kafka代理中提交的偏移量与检查点状态中的偏移量一致。用户可以通过在使用者上调用setCommitofSetsonCheckpoints（布尔）方法来选择禁用或启用偏移量提交（默认情况下，行为为true）。请注意，在此场景中，将完全忽略属性中的自动定期偏移提交设置。

请注意，在这种情况下，属性中的自动定期偏移提交设置被完全忽略