This typical problem in the case where pom.xml does not contain the correct version jar. You must have the same version of the libraries in the pom.xml application that is in a cluster hadoop. etc: <properties> <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> <storm.version>0.10.0.2.4.2.0-258</storm.version> <storm.kafka.version>0.10.0.2.4.2.0-258</storm.kafka.version> <kafka.version>0.9.0.2.4.2.0-258</kafka.version> <hadoop.version>2.7.1.2.4.2.0-258</hadoop.version> <hbase.version>1.1.2.2.4.2.0-258</hbase.version> <log4j.version>1.2.17</log4j.version> <storm.hdfs.version>0.10.0.2.4.2.0-258</storm.hdfs.version> <hive.version>1.2.1000.2.4.2.0-258</hive.version> </properties> <dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka_2.11</artifactId> <version>${kafka.version}</version> <exclusions> <exclusion> <groupId>org.apache.zookeeper</groupId> <artifactId>zookeeper</artifactId> </exclusion> <exclusion> <groupId>org.slf4j</groupId> <artifactId>slf4j-log4j12</artifactId> </exclusion> <exclusion> <groupId>log4j</groupId> <artifactId>log4j</artifactId> </exclusion> </exclusions> </dependency> <!-- Storm Dependencies --> <dependency> <groupId>org.apache.storm</groupId> <artifactId>storm-core</artifactId> <version>${storm.version}</version> <scope>provided</scope> <exclusions> <exclusion> <groupId>org.slf4j</groupId> <artifactId>log4j-over-slf4j</artifactId> </exclusion> <exclusion> <groupId>org.slf4j</groupId> <artifactId>slf4j-log4j12</artifactId> </exclusion> </exclusions> </dependency> <!-- Storm Kafka Dependencies --> <dependency> <groupId>org.apache.storm</groupId> <artifactId>storm-kafka</artifactId> <version>${storm.kafka.version}</version> </dependency> ... View more