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

2017-03-07 Thread Michael Noll
wrote: > Really appreciated, Matthias! > That's what I wanted. > > Regards, > Long Tian > > From: Matthias J. Sax > Sent: 07 March 2017 07:48:08 > To: users@kafka.apache.org > Subject: Re: Can I create user defined stream proc

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 Sent: 07 March 2017 07:48:08 To: users@kafka.apache.org Subject: Re: Can I create user defined stream processing function/api? Hi, you can implements custom ope

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 -Ma

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 cou