Apache Storm Integration With Apache Kafka


Installing Apache Storm

The prerequisite for storm to work on the machine.
a. Download and installation commands for ZeroMQ 2.1.7:
Run the following commands on terminals

b. Download and installation commands for JZMQ:

 

2. Download latest storm from http://storm.apache.org/downloads.html

Second start Storm Cluster by starting master and worker nodes.

Start master node i.e. nimbus.

To start master i.e. nimbus go to the ‘bin’ directory of the Storm installation and execute following command. [separate command line window]

Start worker node i.e. supervisor.

To start worker i.e. supervisor go to the ‘bin’ directory of the Storm installation and execute following command. [separate command line window]

Apache Kafka + Apache Storm

1. Kafka Producer