Re: kafka stream depends on it's own derived table

2019-01-28 Thread Matthias J. Sax
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

kafka stream depends on it's own derived table

2019-01-28 Thread Nan Xu
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