Мы используем стратегию ручного коммита.Мы настроили компонент, который фиксирует все успешно использованные сообщения.Мы пытаемся добавить логику для повторного использования неподтвержденных сообщений.Мы сталкиваемся с проблемой того, что одно и то же сообщение используется, но временной интервал для повторного потребления не является одинаковым.Иногда он быстро перерабатывается, но иногда занимает часы.
Как мы можем быть уверены, что незафиксированные сообщения будут использованы в течение указанного времени.