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
is large enough (1year). Our both streams have 3 partitions.
We noticed that in the KStreams documentation, the following sentence
appears:
* Transforming records might result in an internal data redistribution
if a key based operator (like an aggregation
* or join) is applied to the result {@code KStream}.
* (cf. {@link #transformValues(ValueTransformerSupplier, String...)})
What does this redistribution mean and how does it work? Why have we lost
joins result?
Thank you
