У меня уже реализовано приведенное ниже с ручным фиксированием смещений и его работа без проблем. каждое событие, совершаемое после возврата вызова asyn c Rest. Когда я говорю «зафиксировано», я имею в виду, что кеш помечает событие как обработанное, а смещение фиксируется только в том случае, если все события с меньшими смещениями были обработаны, поскольку ответы Rest могут быть получены не по порядку.
Я закодировал вручную кеш для этого, но есть ли Java API, который мог бы это сделать.