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、排查的很痛苦，希望可以帮到遇到同样错误的人^_^