回复：yarn-session模式通过python api消费kafka数据报错

hi wei zhang, 非常感谢，终于跑起来了，感谢你这么耐心的指导初学者。 我当时从编译的源码中拷贝的时flink-sql-connector-kafka 而不是flink-sql-connector-kafka-0.11，所以版本不必配。 再次感谢，祝工作顺利。 -- 发件人：Wei Zhong 发送时间：2019年12月10日(星期二) 10:23 收件人：改改 抄　送：user-zh 主　题：Re:

回复：yarn-session模式通过python api消费kafka数据报错

HI Wei Zhong , 感谢您的回复，flink的lib目录下已经放了kafka connector的jar包的，我的flink/lib目录下文件目录如下： 另外我的集群环境如下： java ：1.8.0_231 flink: 1.9.1 Python 3.6.9 Hadoop 3.1.1.3.1.4.0-315 昨天试了下用python3.6 执行，依然是报错的，报错如下： [root@hdp02 data_team_workspace]# /opt/flink-1.9.1/bin/flink run -py