Kafka Streams: сбросить таймер окна при поступлении нового сообщения
Моя тема Kafka содержит сообщения с полем id. Я хочу агрегировать сообщения по этому идентификатору, используя временное окно, которое должно быть сдвинуто при появлении дубликата.
Пример:
Я получил сообщение с id = 94, Я хочу дождаться следующего сообщения с id = 94 в течение 30 секунд, и если он не появится, я собираюсь начать его обработку. Но если новое сообщение с id = 94 приходит в течение этих 30 секунд, я хочу сбросить таймер и ждать следующего id = 94 30 секунд больше.
Возможно ли реализовать такую логику, используя Kafka Streams или аналогичную технологию?
Спасибо.