Как потребитель kafka может десериализовать различные объекты json? - PullRequest
0 голосов
/ 26 января 2019

Я пытаюсь найти способ, чтобы потребитель kafka мог читать (десериализовывать) различные сообщения структуры json из темы.Для построения какой-то абстракции можно использовать идентификатор класса.Если кто-то сделал это, я буду рад сообщить.

Приветствия:)

1 Ответ

0 голосов
/ 26 января 2019

См. Пружина для документации Apache Kafka .

JsonDeserializer может использовать информацию о типе в заголовках, чтобы определить, какой тип создать во время десериализации.

Если исходным приложением также является Spring, сериализатор автоматически добавит вам информацию этого типа.

Если нет, вы можете добавить его самостоятельно в заголовок с именем __TypeId__ (по умолчанию).

Значением может быть либо полное имя класса, либо значение токена, если десериализатор сконфигурирован для сопоставления этого значения с именем класса. Снова смотрите документацию.

Если вы не можете установить заголовок и вам нужно проверить JSON, чтобы определить тип, вы можете начать с этого десериализатора и создать собственную версию.

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...