What I am doing here is to stream the data from an existing Kafka topic "topic1", run the data through the ruleengine, and then output the results to "topic1_filtered". The keys in the Kafka topic are Strings and the values are in Avro binary format.
Carpe Diem