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 >
signature.asc
Description: OpenPGP digital signature
