Spring Kafka Consumer класс ошибок приведен при десериализации авро схемы

Question

Я использую Spring Kafka + Schema Registry из слияния. Я сталкиваюсь со странным поведением. Это кусок кода:

@Service
@Slf4j
@RequiredArgsConstructor
public class NfConsumer {
    private final NfInfoService nfInfoService;

    @KafkaListener(topics = "test", groupId = "nf_process",
            topicPartitions = @TopicPartition(topic = "test",
                    partitionOffsets = @PartitionOffset(initialOffset = "0", partition = "0")))
    public void consume(ConsumerRecord<String, NfProcess> record) throws Exception {
        log.info("M=consume, record=" + record);
        nfInfoService.nfStatusHandler(record.value());
    }
}

Проблема в том, что когда я вызываю nfInfoService.nfStatusHandler (record.value ()), я всегда получаю ошибку исключения из класса, но моя среда IDE не указывает на ошибку , Самое странное, что если поставить точку останова, я могу получить доступ к record.value () и его значениям. Я прочитал в stackoverflow, чтобы добавить spring.kafka.consumer.properties.specifi c .avro.reader = true в свойствах, но все еще не работает. У кого-нибудь есть идеи? Я генерирую эти классы, используя avro-maven-plugin.