Spring Boot配置Kafka Avro序列化器/反序列化器报错求助

1. 确认依赖配置正确 #

KafkaAvroSerializer属于Confluent官方包，默认不在Maven中央仓库，需先添加Confluent仓库再引入依赖：

Maven配置 #

在pom.xml中添加仓库：

<repositories>
    <repository>
        <id>confluent</id>
        <url>https://packages.confluent.io/maven/</url>
    </repository>
</repositories>

添加对应版本的依赖（版本需与Kafka、Spring Kafka版本匹配，例如Confluent 7.x对应Kafka 3.x）：

<dependency>
    <groupId>io.confluent</groupId>
    <artifactId>kafka-avro-serializer</artifactId>
    <version>7.5.0</version>
    <scope>compile</scope>
</dependency>

Gradle配置 #

在build.gradle中添加仓库：

repositories {
    maven {
        url "https://packages.confluent.io/maven/"
    }
}

添加依赖：

implementation 'io.confluent:kafka-avro-serializer:7.5.0'

2. 确保Docker构建包含依赖 #

如果使用自定义Dockerfile，需通过多阶段构建保证依赖被正确打包进镜像：

# 构建阶段：编译项目并打包
FROM maven:3.8.6-openjdk-17 AS builder
WORKDIR /app
COPY pom.xml .
RUN mvn dependency:go-offline
COPY src ./src
RUN mvn clean package -DskipTests

# 运行阶段：复制打包好的jar包
FROM openjdk:17-jdk-slim
WORKDIR /app
COPY --from=builder /app/target/your-app.jar app.jar
ENTRYPOINT ["java", "-jar", "app.jar"]

若使用Spring Boot官方Docker插件，默认会自动打包所有依赖，无需额外配置。

3. 补充完整的Avro序列化配置 #

除序列化器类外，还需配置Schema Registry地址（Avro序列化依赖该服务管理 schema），修改application.yml：

spring:
  kafka:
    consumer:
      auto-offset-reset: earliest
      key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
      value-deserializer: org.springframework.kafka.support.serializer.ErrorHandlingDeserializer
      properties:
        spring:
          deserializer:
            key:
              delegate:
                class: org.apache.kafka.common.serialization.StringDeserializer
            value:
              delegate:
                class: io.confluent.kafka.serializers.KafkaAvroDeserializer
        schema.registry.url: "http://你的schema-registry地址:8081"
        specific.avro.reader: true # 使用生成的Avro Java类时开启
    producer:
      key-serializer: org.apache.kafka.common.serialization.StringSerializer
      value-serializer: io.confluent.kafka.serializers.KafkaAvroSerializer
      properties:
        schema.registry.url: "http://你的schema-registry地址:8081"
    properties:
      security:
        protocol: SASL_SSL

4. 本地验证依赖是否存在 #

打包项目后，检查jar包中是否包含目标类：

jar tf target/your-app.jar | grep KafkaAvroSerializer

若输出类路径，说明依赖已正确打包，重新构建Docker镜像即可。

内容的提问来源于stack exchange，提问作者Insanovation