Flinkkafka FlinkKafkaException send data to Kafka old epoch newer producer same transactionalId(代码

Posted 2021-05-16 九师兄

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了Flinkkafka FlinkKafkaException send data to Kafka old epoch newer producer same transactionalId(代码相关的知识，希望对你有一定的参考价值。

文章目录

1.场景1
- 1.1 概述

1.场景1

1.1 概述

java.io.IOException: Could not perform checkpoint 823 for operator OrderDayAggOperator -> (Sink: DayGmvRedisSinkOperator, Sink

以上是关于Flinkkafka FlinkKafkaException send data to Kafka old epoch newer producer same transactionalId(代码的主要内容，如果未能解决你的问题，请参考以下文章

比 FlinkKafka 更有前景！做大数据一定要牢牢掌握的现象级技术！

比 FlinkKafka 更有深度！做大数据一定要牢牢掌握的现象级技术！

重磅！Log4j 爆“核弹级”漏洞，FlinkKafka等至少十多个项目受影响

突发！Log4j 爆“核弹级”漏洞，FlinkKafka等至少十多个项目受影响