1、关键报错信息:

Failed to send data to Kafka xxx with FlinkKafkaInternalProducer{transactionalId=‘xxx’, inTransaction=true, closed=false}

The broker received an out of order sequence number

2、任务截图

在这里插入图片描述

3、错误截图

在这里插入图片描述

4、解决办法

执行后反复报上图的错，排查了很久都没有收获，最后发现是jar包的问题。即使代码已经把依赖打包好了，但是flink集群的lib目录也一定要把相应的jar包放进去，程序提交给flink集群执行时，使用的是集群的lib目录下的jar包
在这里插入图片描述

5、排查的很痛苦，希望可以帮到遇到同样错误的人^_^

# kafka # mysql # java # flink
Logo
华为开发者空间

华为开发者空间，是为全球开发者打造的专属开发空间，汇聚了华为优质开发资源及工具，致力于让每一位开发者拥有一台云主机，基于华为根生态开发、创新。

更多推荐

cover

仓颉之枚举类型与模式匹配的冒险之旅

avatar 华为开发者空间
cover

昇腾数据探险家：挖掘数据的隐藏宝藏

avatar 华为开发者空间
cover

仓颉之包与异常处理的智慧战场

avatar 华为开发者空间