Hi Team Kafka, Currently, I'm working on an small library to implement "complex event processing" on top of Kafka Streams : https://github.com/fhussonnois/kafkastreams-cep
The idea came from the flink-cep library and the project is based on the same research paper. I'm developping this project for fun. But I'm not expert about CEP so maybe I'm doing things wrong ^^ I would like to share with you my work because I think this could interest the kafka community. The project is still in progress but things seem to be on a right way. I've already planned to add a support for KStream DSL. Also, I would like to know if you will plan to add an "external" module in order to add contributions without impacting the kafkastreams APIs? Please feel free to give me your feedback about my API. Thanks for you time and the amazing work you are doing on Kafka. Florian. -- Florian HUSSONNOIS @fhussonnois
