Strimzi部署KafkaConnect时Avro序列化类未识别问题求助
解决方案:添加缺失的Confluent序列化依赖Jar
你的错误根源是缺少kafka-serializers核心依赖包——AbstractKafkaAvroSerializer类就包含在这个包里,当前的插件配置并未引入它。
修复步骤
在你的KafkaConnect容器配置的artifacts列表中,添加对应版本的kafka-serializers Jar包引用:
build: output: type: docker image: <my image> pushSecret: <my secret> plugins: - name: mongodb-connector artifacts: - type: jar url: https://repo1.maven.org/maven2/org/mongodb/kafka/mongo-kafka-connect/1.5.1/mongo-kafka-connect-1.5.1-all.jar - type: jar url: https://repo1.maven.org/maven2/org/apache/avro/avro/1.10.2/avro-1.10.2.jar - type: jar url: https://packages.confluent.io/maven/io/confluent/kafka-connect-avro-converter/7.7.1/kafka-connect-avro-converter-7.7.1.jar - type: jar url: https://packages.confluent.io/maven/io/confluent/kafka-schema-serializer/7.7.1/kafka-schema-serializer-7.7.1.jar - type: jar url: https://packages.confluent.io/maven/io/confluent/kafka-schema-registry-client/7.7.1/kafka-schema-registry-client-7.7.1.jar # 添加缺失的kafka-serializers依赖 - type: jar url: https://packages.confluent.io/maven/io/confluent/kafka-serializers/7.7.1/kafka-serializers-7.7.1.jar
额外注意事项
- 所有Confluent官方依赖的版本必须保持一致(此处统一使用7.7.1),避免版本冲突引发兼容性问题。
- 重新构建并部署KafkaConnect集群后,再次尝试启动连接器,类找不到的错误即可解决。
内容的提问来源于stack exchange,提问作者gt1
相关产品推荐
相关产品推荐

