Консюмер вычитывает сообщение и передаёт в базу через процедуру или инсерт не важно. Проца или инсерт выкидывают исключение. Хендлер это исключение обрабатывает и делает коммит, оффсет сдвигается.
Можно ли сделать так , чтобы оффсет не сдвигался?
Какие мысли у меня.
1 Вариант. Можно , что то придумать и тогда будет вечный ретрай до тех пор пока session timeout позволяет крутиться. Далее консюмер отвалиться по timeout его выкинут из группы, произойдёт ребаланстровка
2 Вариант. Остановить консюмер.
Я боюсь потерять сообщения.
мыслите в терминах классических очередей
Обсуждают сегодня