У меня было дневное окно с первоначальным льготным периодом, установленным как O. Получил новое требование для добавления льготного периода в 15 минут.
Потоковая версия Kafka: 2.1
Фрагмент кода-
KTable, JsonNode> profileAgg = транзакции .groupByKey () .windowedBy (TimeWindows.of (Duration.ofSeconds (86400)).. Grace (Duration.ofSeconds (900)))
Но почему-то яполучение исключения при запуске процесса.Как мне увеличить срок хранения?
Исключение в потоке "main" java.lang.IllegalArgumentException: период хранения хранилища окон KSTREAM-FILTER-0000000001 должен быть не меньше его размера окна плюс период отсрочки.Полученный размер = [86400000], грация = [900000], удержание = [86400000]