I am trying to setup a Local Cluster with Apache Storm to get a basic topology. Currently using Kafka 2.11-0.8.2.1 & Storm 0.9.5. I have a Spout and a Bolt configured, and a couple messages have been passed through the pipeline successfully. I am getting an exception after 2 messages are sent, but don't know why. Might be a compatibility/version issue with the jars. I added many more jars to get this thing running, but it still crashes after sending a couple messages. The exception seems to come from the spout.I am trying to setup a Local Cluster with Apach