Я новичок в Кафке. Я отправляю запрос на сервер REST и отправляю ответ на запрос на сервер kafka в виде сообщений.
Когда я получаю данные от потребителя, сообщение разбивается на несколько небольших сообщений. Как мне этого избежать. Ответ является строкой JSON. Я хочу, чтобы каждая строка JSON была одним сообщением. Любая помощь будет оценена. Размер Json тоже не очень большой. JSON с более чем 1500 строк составляет около 2 МБ
Например,
ConsumerRecord (тема = 'meetup_sample', раздел = 0, смещение = 445386,> Отметка время = 1530554568191, timestamp_type = 0,> ключ = b'5fa4964b035c072a81fedb93cfca8f0ecb562cf913c69f63efbbf4e799871f05' > значение = Ь ': "еда и напитки", "topic_name": "Еда и напитки"}, {"urlkey": "newintown", "topic_name": "New In Town"}, {"urlkey": "beer", "topic_name" ',> checkum = None, serialized_key_size = 64, serialized_value_size = 128)
ConsumerRecord (topic = 'meetup_sample', partition = 0, offset = 445387,> timestamp = 1530554568192, timestamp_type = 0,> key = b'1f170ceabf91335d332487ebb0890f0bd0ed69018c618ecc2c789a2 'url'Bell> значение> be1> be1> be1> be1: be1: значение: be1: be1>: значение: be1> be1: значение: be1: be1: значение: be1 game-night "," topic_name ":" Game Night "}, {" urlkey ":" happy-hours "," topic_name ":" Happy Hour "}, {" urlkey ":" water-s ',> checkum = Нет, serialized_key_size = 64, serialized_value_size = 128)