Thanks for the reply. I re built kafka. And now when I am running server it is stopping saying it cannot find the class Kafka.Kafka. I don't know what went most probably it's an sbt problem. Any help is welcome. Thanks :-) On Jun 5, 2014 6:05 AM, "Joe Stein" <joe.st...@stealth.ly> wrote:
> The build looks fine your error seems valid maybe like your broker(s) > is(are) not up. > > /******************************************* > Joe Stein > Founder, Principal Consultant > Big Data Open Source Security LLC > http://www.stealth.ly > Twitter: @allthingshadoop > ********************************************/ > > > > On Jun 4, 2014, at 8:07 PM, Abhishek Bhattacharjee < > abhishek.bhattacharje...@gmail.com> wrote: > > > > I followed the readme for kafka-0.8.0. > > After I am getting the following warnings > > > >>> ./sbt assembly-package-dependency > > > > [info] Loading project definition from > > /home/abhishek/Project/kafka-0.8.0-src/project > > [warn] Multiple resolvers having different access mechanism configured > with > > same name 'sbt-plugin-releases'. To avoid conflict, Remove duplicate > > project resolvers (`resolvers`) or rename publishing resolver > (`publishTo`). > > [info] Set current project to Kafka (in build > > file:/home/abhishek/Project/kafka-0.8.0-src/) > > [warn] Credentials file /home/abhishek/.m2/.credentials does not exist > > [info] Compiling 213 Scala sources and 2 Java sources to > > /home/abhishek/Project/kafka-0.8.0-src/core/target/scala-2.8.0/classes... > > [warn] > > > /home/abhishek/Project/kafka-0.8.0-src/core/src/main/scala/kafka/api/LeaderAndIsrResponse.scala:66: > > non variable type-argument String in type pattern (String, Int) is > > unchecked since it is eliminated by erasure > > [warn] for ((key:(String, Int), value) <- responseMap) { > > [warn] ^ > > [warn] > > > /home/abhishek/Project/kafka-0.8.0-src/core/src/main/scala/kafka/api/StopReplicaResponse.scala:67: > > non variable type-argument String in type pattern (String, Int) is > > unchecked since it is eliminated by erasure > > [warn] for ((key:(String, Int), value) <- responseMap){ > > [warn] ^ > > [warn] > > > /home/abhishek/Project/kafka-0.8.0-src/core/src/main/scala/kafka/utils/Utils.scala:383: > > non variable type-argument V in type pattern List[V] is unchecked since > it > > is eliminated by erasure > > [warn] case Some(l: List[V]) => m.put(k, v :: l) > > [warn] ^ > > [warn] three warnings found > > [warn] warning: [options] bootstrap class path not set in conjunction > with > > -source 1.5 > > [warn] > > > /home/abhishek/Project/kafka-0.8.0-src/core/src/main/scala/kafka/tools/KafkaMigrationTool.java:261: > > warning: [unchecked] unchecked conversion > > [warn] ProducerThread producerThread = new > > ProducerThread(producerDataChannel, producer, i); > > [warn] > > ^ > > [warn] required: Producer<byte[],byte[]> > > [warn] found: Producer > > [warn] > > > /home/abhishek/Project/kafka-0.8.0-src/core/src/main/scala/kafka/tools/KafkaMigrationTool.java:338: > > warning: [unchecked] unchecked call to KeyedMessage(String,K,V) as a > member > > of the raw type KeyedMessage > > [warn] KeyedMessage<byte[], byte[]> producerData = new > > KeyedMessage((String)topic, null, bytes); > > [warn] ^ > > [warn] where K,V are type-variables: > > [warn] K extends Object declared in class KeyedMessage > > [warn] V extends Object declared in class KeyedMessage > > [warn] > > > /home/abhishek/Project/kafka-0.8.0-src/core/src/main/scala/kafka/tools/KafkaMigrationTool.java:338: > > warning: [unchecked] unchecked conversion > > [warn] KeyedMessage<byte[], byte[]> producerData = new > > KeyedMessage((String)topic, null, bytes); > > [warn] ^ > > [warn] required: KeyedMessage<byte[],byte[]> > > [warn] found: KeyedMessage > > [warn] > > > /home/abhishek/Project/kafka-0.8.0-src/core/src/main/scala/kafka/tools/KafkaMigrationTool.java:371: > > warning: [unchecked] unchecked call to KeyedMessage(String,K,V) as a > member > > of the raw type KeyedMessage > > [warn] private KeyedMessage<byte[], byte[]> shutdownMessage = new > > KeyedMessage("shutdown", null, null); > > [warn] ^ > > [warn] where K,V are type-variables: > > [warn] K extends Object declared in class KeyedMessage > > [warn] V extends Object declared in class KeyedMessage > > [warn] > > > /home/abhishek/Project/kafka-0.8.0-src/core/src/main/scala/kafka/tools/KafkaMigrationTool.java:371: > > warning: [unchecked] unchecked conversion > > [warn] private KeyedMessage<byte[], byte[]> shutdownMessage = new > > KeyedMessage("shutdown", null, null); > > [warn] ^ > > [warn] required: KeyedMessage<byte[],byte[]> > > [warn] found: KeyedMessage > > [warn] 6 warnings > > [info] Including zkclient-0.3.jar > > [info] Including snappy-java-1.0.4.1.jar > > [info] Including zookeeper-3.3.4.jar > > [info] Including metrics-core-2.2.0.jar > > [info] Including metrics-annotation-2.2.0.jar > > [info] Including log4j-1.2.15.jar > > [info] Including scala-compiler.jar > > [info] Including jopt-simple-3.2.jar > > [info] Including slf4j-api-1.7.2.jar > > [info] Including slf4j-simple-1.6.4.jar > > [info] Including scala-library.jar > > [warn] Merging 'META-INF/NOTICE' with strategy 'rename' > > [warn] Merging 'org/xerial/snappy/native/README' with strategy 'rename' > > [warn] Merging 'META-INF/maven/org.xerial.snappy/snappy-java/LICENSE' > with > > strategy 'rename' > > [warn] Merging 'LICENSE.txt' with strategy 'rename' > > [warn] Merging 'META-INF/LICENSE' with strategy 'rename' > > [warn] Merging 'META-INF/MANIFEST.MF' with strategy 'discard' > > [warn] Strategy 'discard' was applied to a file > > [warn] Strategy 'rename' was applied to 5 files > > [info] Packaging > > > /home/abhishek/Project/kafka-0.8.0-src/core/target/scala-2.8.0/kafka-assembly-0.8.0-deps.jar > > ... > > [info] Done packaging. > > [success] Total time: 67 s, completed 5 Jun, 2014 5:31:28 AM > > > > I am not able run my Producer to insert into kafka. > > The server runs but data doesn't go in. LeaderNotAvailableException is > > raised. > > > > Thanks > > -- > > *Abhishek Bhattacharjee* > > *Pune Institute of Computer Technology* >