Разница между joinWindows.of и joinWindows.until в потоках кафки?

Question

Я пытаюсь понять разницу между joinWindows.of и joinWindows.until при выполнении левого соединения.Например,

Stream1.leftJoin(Stream2,SomeJoinerValue,joinWindows.of(2 mins).until(5 mins))

Насколько я понимаю, согласно документации, поскольку разница во времени между Stream1 и Stream2 составляет менее 2 минут, успешное соединение будет выполнено без удаления чего-либо изпотоки.
Мой вопрос здесь заключается в том, как использовать срок хранения Windows 5 минут?

Answer 1

Срок хранения окна - это нижняя граница того, как журнал хранит окно и принимает новые входные данные.Это необходимо для обработки записей, вышедших из строя.Объединения основаны на времени события, и, следовательно, не гарантируется, что все записи будут обработаны в порядке упорядоченных временных отметок.Фактически, Kafka Streams обрабатывал записи в порядке смещения.