RE: Re: Kafka streams event deduplication keeping last event in window

2021-11-03 Thread Luigi Cerone
n find > closed windows, forward the result and also delete the row explicitly, > which give you more control. > > Hope this helps. > > -Matthias > > On 11/2/21 10:29 AM, Luigi Cerone wrote: > > I'm using Kafka Streams in a deduplication events problem over short t

Re: Kafka streams event deduplication keeping last event in window

2021-11-03 Thread Luigi Cerone
n runs you can find > closed windows, forward the result and also delete the row explicitly, > which give you more control. > > Hope this helps. > > -Matthias > > On 11/2/21 10:29 AM, Luigi Cerone wrote: > > I'm using Kafka Streams in a ded

Kafka streams event deduplication keeping last event in window

2021-11-02 Thread Luigi Cerone
I'm using Kafka Streams in a deduplication events problem over short time windows (<= 1 minute). First I've tried to tackle the problem by using DSL API with [`.suppress(Suppressed.untilWindowCloses(...))`]( https://kafka.apache.org/21/documentation/streams/developer-guide/dsl-api.html) operator bu