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