Изменение продолжительности сеанса Kafka Stream SessionWindows итеративно

Question

Предположим, у меня есть поток Кафки с окном Sessio, таким как:

windowedBy(SessionWindows.with(inactivity_time).until(aWeek))

Можно ли будет итеративно изменять интервал времени бездействия окна в зависимости от прибытияследующие записи?

Например, если я изначально определил свой inactivity_time=360000 с первой записью, можно ли будет изменить это значение, если вторая запись того же ключа не поступит после inactivity_time/2?

Answer 1

К сожалению, это невозможно при использовании встроенной функциональности.

Для этого потребуется самостоятельно реализовать эту пользовательскую функцию, например, с помощью Processor API Kafka Streams (получившиеся в результате процессоры / трансформаторы вы могли бы затемподключите к DSL Kafka Streams).