См. Пружина для документации Apache Kafka .
JsonDeserializer
может использовать информацию о типе в заголовках, чтобы определить, какой тип создать во время десериализации.
Если исходным приложением также является Spring, сериализатор автоматически добавит вам информацию этого типа.
Если нет, вы можете добавить его самостоятельно в заголовок с именем __TypeId__
(по умолчанию).
Значением может быть либо полное имя класса, либо значение токена, если десериализатор сконфигурирован для сопоставления этого значения с именем класса. Снова смотрите документацию.
Если вы не можете установить заголовок и вам нужно проверить JSON, чтобы определить тип, вы можете начать с этого десериализатора и создать собственную версию.