Проверяйте сообщения через каждые 10 минут с интервалом kafka - Nodejs - PullRequest
0 голосов
/ 06 декабря 2018

Потребитель должен проверять сообщения с интервалом в 10 минут, это ответное сообщение должно содержать нефиксированное смещение. В настоящее время сообщения получаются после того, как производитель отправил сообщение

1 Ответ

0 голосов
/ 09 декабря 2018

Это не совсем так, как работает Kafka Consumer.Обычно у вас есть бесконечный цикл, и вы просто берете все сообщения, которые вам дают.Если вы не меняете group.id и не фиксируете смещения между запросами, вы всегда будете получать следующий пакет сообщений.

Если вы хотите добавить некоторый предел максимального потребления, а затем 10 минут для ожидания потока в этом цикле, то это подробности реализации вашего приложения, но не специфичные для Kafka

...