感谢你的回复 我看了打的JAR包中是存在org.apache.kafka.common.serialization.Serializer和ByteArraySerializer 在Flink run-application过程中也并没有将集群中Kafka 1.1.1版本的依赖加载到类路径中,并且在HDFS的application_1619417125027_0011/lib下也没有发现Kafka相关的jar包
不太明白为什么会出现问题 这是我的打包配置: <plugin> <groupId>org.apache.maven.plugins</groupId> <artifactId>maven-shade-plugin</artifactId> <version>3.0.0</version> <executions> <execution> <phase>package</phase> <goals> <goal>shade</goal> </goals> <configuration> <artifactSet> <excludes> <exclude>org.apache.flink:force-shading</exclude> <exclude>com.google.code.findbugs:jsr305</exclude> <exclude>org.slf4j:*</exclude> <exclude>log4j:*</exclude> </excludes> </artifactSet> <filters> <filter> <artifact>*:*</artifact> <excludes> <exclude>META-INF/*.SF</exclude> <exclude>META-INF/*.DSA</exclude> <exclude>META-INF/*.RSA</exclude> </excludes> </filter> </filters> <transformers> <transformer implementation="org.apache.maven.plugins.shade.resource.ManifestResourceTransformer"> <mainClass>Main</mainClass> </transformer> </transformers> </configuration> </execution> </executions> </plugin> -- Sent from: http://apache-flink.147419.n8.nabble.com/