java - AVRO 类转换异常

Question

嗨，所以在我的 spring 监听器消费者中，当我尝试获取值时，我不断抛出以下错误..

  public void listen(ConsumerRecord<String, Car> consumerRecord) {
    Car value = consumerRecord.value();
    int i= 0;
}

---

  java.lang.ClassCastException: class org.apache.avro.generic.GenericData$Record cannot be cast to class com.test.avro.Car (org.apache.avro.generic.GenericData$Record and com.test.avro.Car are in unnamed module of loader 'app')

Answer 1

我需要将以下内容添加到配置中

props.put(KafkaAvroDeserializerConfig.SPECIFIC_AVRO_READER_CONFIG, "true");