Maybe it’s not what you are looking for, but I think that functionality can
be implemented in two steps.
First, you perform a LEFT join, and then you filter by “null” on the joined
field to identify those whose joins didn’t succeed.
HTH,
Rubén
El El mar, 16 mar 2021 a las 5:34, Ross Black
escr
I think what you described can be accomplished using the low-level API
(perhaps by implementing a custom Transformer).
You would create your own store for this Transformer to use, and implement
your own join logic which includes emitting these records for secondary
events that couldn't be joined w
Hi,
I am trying to find the best pattern to solve a specific problem using
Kafka streaming. All of our current processing uses the Kafka streaming
API (using multiple joins, windows, repartitions etc) so I already think I
have a decent grasp of the fundamentals.
We have 2 streams of events:
- pr
