I have built a storm topology, that consumes data from kafka and writes into hdfs. When using storm & kafka dependencies like below, <storm.version>0.10.0.2.3.4.0-3485</storm.version> <kafka.version>0.8.2.1</kafka.version> topology is failing with below stated exception: **java.lang.NoSuchMethodError: kafka.javaapi.consumer.SimpleConsumer.<init>(Ljava/lang/String;IIILjava/lang/String;Ljava/lang/String;)V at storm.kafka.DynamicPartitionConnections.register(DynamicPartitionConnections.java:60) at storm.kafka.PartitionManager.<init>(PartitionManager.java:66) at storm.kafka.ZkCoordinator.refresh(ZkCoordinator.java:98) at storm.kafka.ZkCoordinator.getMyManagedPartitions(ZkCoordinator.java:69) at storm.kafka.KafkaSpout.nextTuple(KafkaSpout.java:138) at backtype.storm.daemon.executor$fn__7098$fn__7113$fn__7142.invoke(executor.clj:596) at backtype.storm.util$async_loop$fn__543.invoke(util.clj:475) at clojure.lang.AFn.run(AFn.java:22) at java.lang.Thread.run(Thread.java:745)** But, When using storm & kafka dependencies like below topology is running fine and downloading messages and writing to hdfs , without any issues!! <storm.version>0.9.3.2.2.4.0-2633</storm.version> <kafka.version>0.8.2.1</kafka.version> Can someone please help what is the causing the issue and help me fix the issue ! ... View more

Can someone pls help me creating regex pattern to use for creating a hive table with RegEx Serde.... I want hive regex table to be created with the pattern ^^^^^^^^^^ [10 anchor characters] as a delimiter! I am not sure what would be the regex pattern of hive table for this!! please help. Thanks a lot in advance ... View more