提交fink任务到yarn 报 kafka producer 初始化错误

1.报错截图

当时没有截图

2.报错信息

org.apache.kafka.common.serialization.ByteArraySerializer的一个对象 这个类不是 org.apache.kafka.common.serialization.Serializer的实例。      

3.解决错误

1） 错误原因

这个错误是由于因为要使用kafkaSink 所以要导入下面这个依赖。

然后这个依赖依赖 kafka-client。但是他依赖的kafka-client不一定和你的kafka的版本一样。但是在本地测试可以跑。不报错。提交到yarn上跑就报错了。~~~ 不知道为什么

2） 解决错误

先排除那个版本的kafka-clients。然后打包上传。最后自己下载好对应的kafka-clients的jar包。上传到flink的lib目录那么就解决错误了。