Как изменить время окна в потоке?

Question

У меня есть поток, который выполняет агрегирование по времени с использованием окон в течение 5 минут.

Могу ли я динамически изменять этот параметр с 5 до 4 минут с помощью кода программы?

Не создается тот же поток .

Мне нужно сделать выбор из условия, зависящего от потока, если количество данных больше 1000, подождите 4 минуты, если меньше, подождите 5 минут.

Answer 1

Я не думаю, что то, о чем вы спрашиваете, в настоящее время возможно в ksqlDB. Похоже, что вам нужно что-то вроде окна сеанса, где окно сеанса закрывается на основании чего-то другого, кроме времени, например, на основе некоторого количества.

Хотя это невозможно с абстрактным более высоким уровнем ksqlDB, возможно с Kafka Streams. Вы можете взглянуть на это.