Некогерентный ответ производителя Кафки - PullRequest
0 голосов
/ 27 апреля 2019

Я реализую Kafka listerner (Consumer) с загрузкой Spring, событие приходит к методу, который должен его обрабатывать, но данные, которые должны быть json в виде строкового ответа, поступают как-то в виде огромной строки, разделенной запятыми.

Я издевался над источником, который отправлял данные брокеру Kafka, работающему в док-контейнере как с Junit, так и передавая параметры через интерфейс командной строки докера.Брокер a busy cat

Потребительский класс: a busy cat

Мне нужно получить эту строку с реальным значением, то есть json как строку, которую я отправил брокеру Кафки.

...