Comments 2
1) Я сейчас смотрю топик куда складываются окна ,и вижу что там меняются значение на каждое значение, ели ты например отсылаешь после этого уведомления и ожидаешь 1 нзачение финальное, то будешь сильно удивлен что перед финальным послались все изменения. В кафка стриме есть FINAL или что еще чтобы в output посылался только финальный результат?
2) попробовал вариант чтобы окно закрывалось через несколько времени. И что я вижу что при потоке сообщений всё работает корретно, окно закрывается, НО если остановить поток новых сообщений, то ПОСЛЕДНЕЕ окно будет висеть и не flush'иться пока я еще 1 сообщение не закину. это что вообще за бред поведение ?
Sign up to leave a comment.
Kafka Streams ч5: настройка окон, работа с задержанными событиями и suppression