This section will help you create IP Fraud detection application with the help of Apache Kafka and Apache Storm. Storm will read data from Kafka topic, which contains IP log records, and then will do the necessary detection processing and dump the records into hive and Kafka simultaneously. Our Topology consist of following component:
- Kafka Spout: It will read a Stream of records from Kafka and will send it to two bolts
- Fraud Detector Bolt: This bolt will process the record emitted by Kafka spout and will emit fraud records to Hive and Kafka bolt
- Hive Bolt: This bolt will read the data emitted by fraud detector bolt and will process and push those records to hive table
- Kafka Bolt: This bolt will do the same processing ...
