засунули messageType в пейлоад(ака сам жсон содержит свой тип) - spring-kafka по дефолту смотрит в хедер. Как сконфигурировать консьюмера, чтобы в @KafkaHandler метод прилетал десереализированный объект?
ExtendedDeserializer можно задать, чтобы смотреть хереды в момент десериализации. Метод для @KafkaHandler может быть generic, по маркер-интерфейсу например. Если тип в самом json, jackson умеет брать тип из поля.
Обсуждают сегодня