Re: KStream.groupByKey().aggregate() is always emitting record, even if nothing changed

2020-02-25 Thread Adam Rinehart
t "aggregate" is > > connected to, and read / check if the corresponding entry is already > > `success`, if yes let `transformValue` to return `null` which means > forward > > nothing to the downstream. > > > > The reason to use transformValues instead of t

KStream.groupByKey().aggregate() is always emitting record, even if nothing changed

2020-02-24 Thread Adam Rinehart
So I am trying to process incoming events, that may or may not actually update the state of my output object. Originally I was doing this with a KStream/KTable join, until I saw the discussion about "KTable in Compact Topic takes too long to be updated", when I switched to groupByKey().aggregate().