Main code

Our producer application is designed like a real-time log producer, which produces a new record with random IP addresses also in which the producer runs every three seconds. You can add a few records in the IP_Log.log file and producing millions of unique records from those three records will be taken care of by the producer.

We have also enabled the auto-creation of topics, so you need not create a topic before running your producer application. You can change the topic name in the file, mentioned previously:

package com.packt.storm.producer;import com.packt.storm.reader.PropertyReader;import org.apache.kafka.clients.producer.KafkaProducer;import org.apache.kafka.clients.producer.ProducerRecord;import org.apache.kafka.clients.producer.RecordMetadata; ...

Get Mastering Hadoop 3 now with the O’Reilly learning platform.

O’Reilly members experience books, live events, courses curated by job role, and more from O’Reilly and nearly 200 top publishers.