Re: Stream branching and states

2019-10-06 Thread Sophie Blee-Goldman
Hi Navneeth, I think your plan to implement branching with the Processor API sounds reasonable, but I'm wondering why not just use the DSL branch operator and connect some transformers? That will let you mix the DSL and PAPI so you don't have to re-implement anything that is already in the DSL.

Re: Stream branching and states

2019-10-05 Thread Navneeth Krishnan
Hi All, I'm waiting for inputs to proceed with my POC and convert existing applications from flink to kafka streams. It would be really helpful if I can get some clarity on this. Thanks On Wed, Oct 2, 2019 at 7:05 PM Navneeth Krishnan wrote: > Hello All, > > Any inputs? > > Thanks > > On Tue,

Re: Stream branching and states

2019-10-02 Thread Navneeth Krishnan
Hello All, Any inputs? Thanks On Tue, Oct 1, 2019 at 12:40 PM Navneeth Krishnan wrote: > Hi All, > > I found the below example on how branching can be achieved with kafka > streams. I want to implement the same with processor API and the way I get > it is to have the same input topic

Stream branching and states

2019-10-01 Thread Navneeth Krishnan
Hi All, I found the below example on how branching can be achieved with kafka streams. I want to implement the same with processor API and the way I get it is to have the same input topic processed with multiple process functions and output the data based on the filters. Is this the right