It might be easier to use a `Transformer` with a state store. Each time
you receive an input record, you first check if the parent entry is in
the store. If yes, add the new record, otherwise not.
-Matthias
On 1/28/19 2:37 PM, Nan Xu wrote:
> hi,
> I was writing a simple stream app, all it does i
hi,
I was writing a simple stream app, all it does is producer send a sequence
of path and value, for example
path /0 , value 1
path /0/1, value 2
path /0/1/2, value 3
and kafka stream take those input and produce a ktable store.
There is a rule. if parent path is not exist, then child can not i