Kafka Stream Suppress session-windowed-aggregation
That is expected behavior. Note, that suppress()
is based on event-time. Thus, as long as no new data arrives, time cannot advance and thus evicting the record earlier would be wrong, because there is no guarantee, that the next record might belong to the current window.