We will use the same use case of IP Fraud Detection which we used in Chapter 5, Building Spark Streaming Applications with Kafka. Let us begin with the code and how it works. Copy the following classes from Chapter 5, Building Spark Streaming Applications with Kafka, into your Storm Kafka use case:
pom.xml:
<?xml version="1.0" encoding="UTF-8"?><project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> <modelVersion>4.0.0</modelVersion> <groupId>com.packt</groupId> <artifactId>chapter6</artifactId> <version>1.0-SNAPSHOT</version> <properties> <project.build.sourceEncoding ...
