Spring消费者监听中AVRO ClassCastException异常求助

• 核心原因：Kafka消费者默认将Avro消息反序列化为通用的GenericData$Record，而非你定义的com.test.avro.Car实体类，直接强转就会抛出类型转换异常。

• 解决方案：

  1. 配置特定Avro反序列化器并开启具体类读取
     在Spring Kafka消费者配置中，指定Avro专用反序列化器，同时设置specific.avro.reader=true，让反序列化器生成你定义的Car类实例而非通用Record。
     示例application.yml配置：

     spring:
       kafka:
         consumer:
           bootstrap-servers: your-kafka-address:9092
           key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
           value-deserializer: io.confluent.kafka.serializers.KafkaAvroDeserializer
           properties:
             schema.registry.url: http://your-schema-registry-address:8081
             specific.avro.reader: true
     

     如果是手动创建消费者工厂，需将参数加入配置Map：

     @Bean
     public ConsumerFactory<String, Car> consumerFactory() {
         Map<String, Object> config = new HashMap<>();
         config.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, "your-kafka-address:9092");
         config.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class);
         config.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, KafkaAvroDeserializer.class);
         config.put(KafkaAvroDeserializerConfig.SCHEMA_REGISTRY_URL_CONFIG, "http://your-schema-registry-address:8081");
         config.put(KafkaAvroDeserializerConfig.SPECIFIC_AVRO_READER_CONFIG, true);
         return new DefaultKafkaConsumerFactory<>(config);
     }
     

  2. 确认Car类的正确性
     确保com.test.avro.Car是通过Avro工具（如avro-maven-plugin、gradle-avro-plugin）根据对应Schema生成的类，且类的全限定名与Schema中的namespace和name完全一致，否则反序列化器仍会使用通用Record。

  3. 检查依赖匹配
     确保项目引入了正确版本的Confluent Avro序列化依赖，版本需与Kafka、Schema Registry版本匹配：
     Maven依赖示例：

     <dependency>
         <groupId>io.confluent</groupId>
         <artifactId>kafka-avro-serializer</artifactId>
         <version>your-confluent-version</version>
     </dependency>
     

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