Deploy the Kafka topology on Storm cluster

The deployment of Kafka and Storm integration topology on the Storm cluster is similar to the deployment of other topologies. We need to set the number of workers and the maximum spout pending Storm config and we need to use the submitTopology method of StormSubmitter to submit the topology on the Storm cluster.

Now, we need to build the topology code as mentioned in the following steps to create a JAR of the Kafka Storm integration topology:

1. Go to project home.
2. Execute the command:

mvn clean install

The output of the preceding command is as follows:

------------------------------------------------------------------ -----
[INFO] ----------------------------------------------------------- -----
[INFO] BUILD SUCCESS
[INFO] ----------------------------------------------------------- -----
[INFO] Total time: 58.326s
[INFO] Finished at:
[INFO...