Building Data Streaming Applications with Apache Kafka

Property reader

We are going to use the same property file and property reader that we used in Chapter 6, Building Storm Application with Kafka, with a few changes. Kafka Stream will read the record from the iprecord topic and will produce the output to the fraudIp topic: 

topic=iprecordbroker.list=localhost:9092output_topic=fraudIp

Here is the property reader class:

package com.packt.Kafka.utils;import java.io.FileNotFoundException;import java.io.IOException;import java.io.InputStream;import java.util.Properties;public class PropertyReader {    private Properties prop = null;    public PropertyReader() {        InputStream is = null;        try {            this.prop = new Properties();            is = this.getClass().getResourceAsStream("/Streaming.properties");            prop.load(is); ...