flink12同时使用flink-connector-kafka和flink-sql-connector-kafka会引发类冲突问题

Fri, 25 Dec 2020 18:38:15 -0800 

在yarn中部署streaming程序，maven使用依赖
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-connector-kafka-2.2_2.11</artifactId>
<version>1.12.0</version>
</dependency>
在flink的lib目录中有flink-sql-connector-kafka_2.11-1.12.0.jar，因为类冲突问题会引起在yarn中程序部署失败，flink默认类加载机制child-first，改为parent-first也样，类冲突问题可以参考http://apache-flink.147419.n8.nabble.com/Kafka-Consumer-td3475.html
org.apache.kafka.common.KafkaException: 
org.apache.flink.kafka.shaded.org.apache.kafka.common.serialization.ByteArrayDeserializer
 is not an instance of org.apache.kafka.common.serialization.Deserializer


不会提ISSUE，还请社区修复

回复