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*
