You need to enable JavaScript to run this app.
优惠活动
大模型
产品
解决方案
定价
更多

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

相关产品推荐
方舟 Agent Plan

超全模态模型 × Harness 升级,最新支持 Deepseek-V4.1-Flash、GLM-5.3 系列、Doubao-Seedream-5.0-pro、Kimi-K3 (部分), 限时 9.9 元起

最近更新时间:2026.06.15 23:44:54