Instantly reminded me of Streams API, where you can use Java8 streams semantics (filter being one of them) to do the first thing in Gouzhang's response (filter messages from one topic into another - I assume that's what you were looking for).
Marko Bonaći Monitoring | Alerting | Anomaly Detection | Centralized Log Management Solr & Elasticsearch Support Sematext <http://sematext.com/> | Contact <http://sematext.com/about/contact.html> On Tue, Apr 26, 2016 at 6:22 PM, Guozhang Wang <wangg...@gmail.com> wrote: > Hi Subramanian, > > Could you elaborate a bit more on "filtering"? Do you want to read raw data > from Kafka, and send the filtered data back to Kafka as a separate topic, > or do you want to read raw data from an external service and send the > filtered data into Kafka? > > > Guozhang > > > On Tue, Apr 26, 2016 at 8:07 AM, Subramanian Karunanithi < > subub...@gmail.com > > wrote: > > > Hi, > > > > Do we have any plugin which is available, which can be used as a > filtering > > mechanism on the data it's working on? > > > > Regards, > > Subramanian. K > > > > > > -- > -- Guozhang >
