Я реализую Kafka listerner (Consumer) с загрузкой Spring, событие приходит к методу, который должен его обрабатывать, но данные, которые должны быть json в виде строкового ответа, поступают как-то в виде огромной строки, разделенной запятыми.
Я издевался над источником, который отправлял данные брокеру Kafka, работающему в док-контейнере как с Junit, так и передавая параметры через интерфейс командной строки докера.Брокер
Потребительский класс:
Мне нужно получить эту строку с реальным значением, то есть json как строку, которую я отправил брокеру Кафки.