Demonstrates filtering on Streaming data simulated via a Kafka topic. Sample data used is Airline Ontime data. The (raw) data is filtered by Storm, and the cleaned-up data is pushed to another Kafka topic.
- Kafka running on localhost with a topic named
raw
andproc
mvn package -DskipTests=true
{project-dir}$ storm jar target/poc2-1.1.1.jar org.pgmx.cloudpoc.poc2.topology.KafkaLocalReaderTopology