Re: Can I create user defined stream processing function/api?

2017-03-07 Thread Michael Noll
ngt...@outlook.com> wrote: > Really appreciated, Matthias! > That's what I wanted. > > Regards, > Long Tian > > From: Matthias J. Sax <matth...@confluent.io> > Sent: 07 March 2017 07:48:08 > To: users@kafka.apache.org > Sub

Re: Can I create user defined stream processing function/api?

2017-03-07 Thread LongTian Wang
Really appreciated, Matthias! That's what I wanted. Regards, Long Tian From: Matthias J. Sax <matth...@confluent.io> Sent: 07 March 2017 07:48:08 To: users@kafka.apache.org Subject: Re: Can I create user defined stream processing function/api? Hi, y

Re: Can I create user defined stream processing function/api?

2017-03-06 Thread Matthias J. Sax
Hi, you can implements custom operator via process(), transform(), and transform() values. Also, if you want to have even more control over the topology, you can use low-level Processor API directly instead of DSL. http://docs.confluent.io/current/streams/developer-guide.html#processor-api

Can I create user defined stream processing function/api?

2017-03-06 Thread Wang LongTian
Dear folks, Background: I'm leaning Kafka stream and want to use that in my product for real time streaming process with data from various sensors. Question: 1. Can I define my own processing function/api in Kafka stream except the predefined functions like groupby(), count() etc.? 2. If I