@Shahzad Aslam Any updates? ... View more

The no such method exception generally points to class conflict and stems from having the wrong versions in your pom.xml. Check your HDP stack and versions in ambari and make sure that your Zookkeeper, Storm, and Kafka dependencies are the correct versions. <dependencies> <dependency> <groupId>org.apache.storm</groupId> <artifactId>storm-core</artifactId> <version>0.10.0</version> <scope>provided</scope> <exclusions> <exclusion> <groupId>org.slf4j</groupId> <artifactId>slf4j-log4j12</artifactId> </exclusion> <exclusion> <groupId>log4j</groupId> <artifactId>log4j</artifactId> </exclusion> </exclusions> </dependency> <dependency> <groupId>org.apache.zookeeper</groupId> <artifactId>zookeeper</artifactId> <version>3.4.6</version> <exclusions> <exclusion> <groupId>org.slf4j</groupId> <artifactId>slf4j-log4j12</artifactId> </exclusion> <exclusion> <groupId>log4j</groupId> <artifactId>log4j</artifactId> </exclusion> </exclusions> </dependency> <dependency> <groupId>org.apache.storm</groupId> <artifactId>storm-hdfs</artifactId> <version>0.10.0</version> <exclusions> <exclusion> <groupId>org.slf4j</groupId> <artifactId>slf4j-log4j12</artifactId> </exclusion> <exclusion> <groupId>log4j</groupId> <artifactId>log4j</artifactId> </exclusion> </exclusions> </dependency> <dependency> <groupId>org.apache.storm</groupId> <artifactId>storm-kafka</artifactId> <version>0.10.0</version> <exclusions> <exclusion> <groupId>org.slf4j</groupId> <artifactId>slf4j-log4j12</artifactId> </exclusion> <exclusion> <groupId>log4j</groupId> <artifactId>log4j</artifactId> </exclusion> </exclusions> </dependency> <dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka_2.10</artifactId> <version>0.8.2.2</version> <exclusions> <exclusion> <groupId>org.apache.zookeeper</groupId> <artifactId>zookeeper</artifactId> </exclusion> <exclusion> <groupId>log4j</groupId> <artifactId>log4j</artifactId> </exclusion> </exclusions> </dependency> <dependency> <groupId>org.apache.storm</groupId> <artifactId>storm-hbase</artifactId> <version>0.10.0</version> <exclusions> <exclusion> <groupId>org.slf4j</groupId> <artifactId>slf4j-log4j12</artifactId> </exclusion> <exclusion> <groupId>log4j</groupId> <artifactId>log4j</artifactId> </exclusion> </exclusions> </dependency> <dependency> <groupId>org.apache.hbase</groupId> <artifactId>hbase-client</artifactId> <version>1.1.1</version> <exclusions> <exclusion> <groupId>org.slf4j</groupId> <artifactId>slf4j-log4j12</artifactId> </exclusion> <exclusion> <groupId>log4j</groupId> <artifactId>log4j</artifactId> </exclusion> </exclusions> </dependency> ... View more

+1, please share. ... View more

@Shahzad Aslam has this been resolved? Can you post your solution or accept best answer? ... View more

Hi, Iam having same issue using Java. More than 30secs to send single message and Kafka consumer running on separate window does not show the message. I am using Kafka 0.10 version. Have you figured out the solution? Any inputs truly appreciated. ... View more

@Shahzad Aslam Did you review the Storm Graphite ? http://www.michael-noll.com/blog/2013/11/06/sending-metrics-from-storm-to-graphite/#integrating-storm-with-graphite ... View more

I ran into this issue as well. Ambari uses port 6667 for Kafka, also if you are using the sandbox you need to use 'sandbox' or 'sandbox.hortonworks.com' not 'localhost' to connect to Kafka. You can change this by setting advertised.host.name property. ... View more

this is the same comment i posted accedently above absolutely no idea about this this is part of challenge i got from a potential employer and i don't want to ask him how to get challenge files from there as it look like this is part of challenge that how i retrieve information from there. it look like that i need to restore it with new hadoop installation administration is not what i am good in so step to do so will be highly appreciated Shahzad ... View more