事务的超时时间
“如果从 Flink 应用程序崩溃到完全重启的时间超过了 Kafka 的事务超时时间，那么将会有数据丢失”
老师 这句话要怎么理解了 两个都设置成1小时 就不会丢数据了？
4
收起
正在回答
1回答
这句话简单理解是这样的：
FlinkKafkaProducer中设置的有一个事务超时时间。
kafka中设置的也有一个事务超时时间。
FlinkKafkaProducer中的事务需要依赖于kafka中的事务。
但是现在FlinkKafkaProducer中的事务超时时间是1小时，而kafka中事务的超时时间才15分钟。
由于FlinkKafkaProducer中的事务需要依赖于kafka中的事务，所以FlinkKafkaProducer中的事务超时时间不能大于kafka中事务的超时时间，否则就会出问题了。
所以这两个事务的超时时间需要保持一致，这样就不会乱套了。
恭喜解决一个难题，获得1积分~
来为老师/同学的回答评分吧
0 星