бизщннеслогике прилёг на 2 часа паредположим.
я обрабатывал 100 сообщение когда он прилёг, офсет не комитил т.к. всё упало.
потом приходит 101 сообщение и я обрабатываю 100е
потом приходит уже 151-е сообщение и я по прежнемуц обрабатываю 100е
Потом микросервис поднялся и стал отвечать 200-ками, я успешно обработал и закомитил оофсет 101
потом приходит 152-е сообщение и я обрабатываю 101-е
потом 153-е пришло - обрабатываю- 102-е - короче отстаю на ~50 сообщений.
Каким образом сокращается оставание?
Обрабатывай быстрее чем они поступают
консюмер будет читать пока есть лаг
ну вот и ответ походу, как только я обработал 100-е сообщение и в логе уже лежат 150, я не буду ждать 151-е чтобы обработать 101-е, так? Просто буду обрабатывать всё что есть в логе
Обсуждают сегодня