не закомитит, офсет останется на том же месте, получается при поступлении каждого нового сообщения, чтение будет с прежнегго офсета? Если да то после обработки этого сообщения сразу же консумер тригернётся для обработки offset+1 сообщения? Или он тригернётся только по приходу нового? Кароче когда и как офсет перестанет “отставать”
когда произойдет коммит оффсета
ваше приложение само коммитит оффсет когда посчитает что операция успешно завершена, до тех пор будете читать одно и тоже сообщение
Обсуждают сегодня