Hello Edmondo,
If you have a join operator following the transform() operator, then the
joining streams will be sent to a repartition topic, and the join
operator's hosted thread will then read from that repartition topic. This
is for "re-shuffling" the streams since the key of the stream record m
Hello users,
we are performing a Transform so that out of a larger message we emit a new
output record only if that specific field has changed.
Since we introduced that to reduce the number of output records, our final
Kstream - KStream windowed join is not ticking anymore, although the window
i
