Building Data Streaming Applications with Apache Kafka

Use case – log processing in Storm, Kafka, Hive

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 ...