假设我的Checkpoint超时时间15min，kafka transcation超时时间10min，在Checkpoint长时间卡住，超过了事务超时时间，这种情况是不是就有问题了 ？
赵珩 <[email protected]> 于2021年12月31日周五 21:23写道： > 我的理解是超过kafka transaction > timeout时间重启flink任务才会发生未提交数据丢失的情况， > kafka不会无限期的保存未提交事务数据。 > 正常情况下的flink重启是不会出现数据丢失的。 > > 在 2021/12/31 11:31, zilong xiao 写道: > > 看官方文档中有介绍说当kafka事务超时时，可能会出现数据丢失的情况，那就是说，Flink没办法完全保证端到端exactly > > once是么？想请教下社区大佬，我这么理解是正确的吗？一直都听说Flink 写kafka是可以保证端到端exactly > once的，看到文档描述有点懵 > > > > 文档地址： > > > https://nightlies.apache.org/flink/flink-docs-release-1.13/docs/connectors/datastream/kafka/#kafka-producers-and-fault-tolerance > > > > 关键字："If the time between Flink application crash and completed restart is > > larger than Kafka’s transaction timeout there will be data loss (Kafka > will > > automatically abort transactions that exceeded timeout time)." >
