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, 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 -Matthias On 3/6/17 3:33 PM, Wang LongTian wrote: > 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 could define my own function, could you please specify a example or > introduce me a github project for example? > > Thank u in advance! > > Regards, > Long Tian >
