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*
