Kafka Streaming with filters

[Su...@cognizant.com]

Dear Team

                We are doing a poc on filtering option in kafka streaming with spring cloud binder.
Specifically with @StreamListener and condition. Is there any java sample applications with the filtering concepts? If there please let me know.
The usecase is:
Messages are published from upstream to multiple topics.Each and every topics has listeners,but only listens to the specific messages which they are intended to operate/process.The messages are identified using KStream filters (Predicates with any business specific conditions like account_no, message_type, etc).
The filter option in kafka streams retain the messages based on the predicates and left those which are false.

Thanks & Regards
    Subbu

This e-mail and any files transmitted with it are for the sole use of the intended recipient(s) and may contain confidential and privileged information. If you are not the intended recipient(s), please reply to the sender and destroy all copies of the original message. Any unauthorized review, use, disclosure, dissemination, forwarding, printing or copying of this email, and/or any action taken in reliance on the contents of this e-mail is strictly prohibited and may be unlawful. Where permitted by applicable law, this e-mail and other e-mail communications sent to and from Cognizant e-mail addresses may be monitored.