Как обработать раздвижное окно с помощью карафки?

У меня есть поток сообщений в теме Kafka. Для каждого сообщения мне нужно проверить предыдущие сообщения, которые появляются в течение 10 секунд после текущего сообщения.

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