I am using kafka with storm. I am using maven to build my topology and I am using scala 2.9.2 same as I am using kafka_2.9.2_0.8.1.
Topology build perfectly using maven. But hwn I submit the topology to storm I get the following Exception: java.lang.NoSuchMethodError: scala.Predef$.int2Integer(I)Ljava/lang/Integer; at kafka.api.OffsetRequest$.(OffsetRequest.scala:28) at kafka.api.OffsetRequest$.(OffsetRequest.scala) at kafka.consumer.ConsumerConfig$.(ConsumerConfig.scala:36) at kafka.consumer.ConsumerConfig$.(ConsumerConfig.scala) at kafka.consumer.SimpleConsumer.(SimpleConsumer.scala:35) at kafka.javaapi.consumer.SimpleConsumer.(SimpleConsumer.scala:35) at storm.ubiquitous.spouts.KafkaConsumer.fetchdata(KafkaConsumer.java:41) at storm.ubiquitous.spouts.KafkaSpoutTransaction$KafkaPartitionedEmitter.emitPartitionBatchNew(KafkaSpoutTransaction.java:92) at storm.ubiquitous.spouts.KafkaSpoutTransaction$KafkaPartitionedEmitter.emitPartitionBatchNew(KafkaSpoutTransaction.java:68) at backtype.storm.transactional.partitioned.PartitionedTransactionalSpoutExecutor$Emitter$1.init(PartitionedTransactionalSpoutExecutor.java:77) at backtype.storm.transactional.state.RotatingTransactionalState.getState(RotatingTransactionalState.java:82) at backtype.storm.transactional.state.RotatingTransactionalState.getStateOrCreate(RotatingTransactionalState.java:103) at backtype.storm.transactional.partitioned.PartitionedTransactionalSpoutExecutor$Emitter.emitBatch(PartitionedTransactionalSpoutExecutor.java:73) at backtype.storm.transactional.partitioned.PartitionedTransactionalSpoutExecutor$Emitter.emitBatch(PartitionedTransactionalSpoutExecutor.java:50) at backtype.storm.transactional.TransactionalSpoutBatchExecutor.execute(TransactionalSpoutBatchExecutor.java:48) at backtype.storm.coordination.CoordinatedBolt.execute(CoordinatedBolt.java:308) at backtype.storm.daemon.executor$fn__3498$tuple_action_fn__3500.invoke(executor.clj:615) at backtype.storm.daemon.executor$mk_task_receiver$fn__3421.invoke(executor.clj:383) at backtype.storm.disruptor$clojure_handler$reify__2962.onEvent(disruptor.clj:43) at backtype.storm.utils.DisruptorQueue.consumeBatchToCursor(DisruptorQueue.java:87) at backtype.storm.utils.DisruptorQueue.consumeBatchWhenAvailable(DisruptorQueue.java:61) at backtype.storm.disruptor$consume_batch_when_available.invoke(disruptor.clj:62) at backtype.storm.daemon.executor$fn__3498$fn__3510$fn__3557.invoke(executor.clj:730) at backtype.storm.util$async_loop$fn__444.invoke(util.clj:403) at clojure.lang.AFn.run(AFn.java:24) at java.lang.Thread.run(Thread.java:724) I searched around and realized that its version related error. But both my compile-time and run-time Scala versions are same(2.9.2) still I am getting the error. Any help is appreciated ! Thanks -- *Abhishek Bhattacharjee* *Pune Institute of Computer Technology*