Интеграция Spring Kafka Listener (DSL), который принимает сообщения из раздела Kafka и десериализует полезную нагрузку сообщения в объект JSON POJO. Потребитель настроен правильно для получения объекта типа A. Но когда сообщение используется, слушатель темы весенней интеграции kafka, оно десериализуется как объект типа B. Большинство полей в Объекте A и Объекте B одинаковы, за исключением нескольких полей.
Когда я использую сообщение по теме kafka с помощью консольного потребительского инструмента, оно правильно использует сообщение как объект типа B и отображает все поля.
Пожалуйста, найдите версию и информацию о брокере ниже.
springKafkaVersion = 2.1.5.RELEASE
springIntegrationVersion = 2.0.3.RELEASE
springIntegrationKafkaVersion = 3.0.3.RELEASE
kakfa client 1.0.1