Kafka, mail # user - RE: LeaderNotAvailableException: reventing the running of kafka-console-producer.bat - 2013-04-26, 04:17
 Search Hadoop and all its subprojects:

Switch to Threaded View
Copy link to this message
-
RE: LeaderNotAvailableException: reventing the running of kafka-console-producer.bat
Yes, like in KAFKA-876's producer log, I only get one
LeaderNotAvailableException.   Thanks for fixing this issue, though could it
only be fixed in the 0.8 branch?  A colleague is having the issue tonight
and I think he may be on the trunk.
Like KAFKA-876, I am now getting the

WARN [KafkaApi-0] Produce request: Leader not local for partition
[test,0] on broker 0 (kafka.server.KafkaApis)

in the broker.log.  4 of them, for the 4 "Hello"s in the producer log.

thanks for your help,
rob
KAFKA-876.
wait
work
package.
can't
if
info.
Do
kafka.cluster.Partition.getOrCreateReplica(Partition.scala:81)
kafka.cluster.Partition$$anonfun$2.apply(Partition.scala:145)
kafka.cluster.Partition$$anonfun$2.apply(Partition.scala:145)
got
zxid:0xfffffffffffffffe
zxid:0xfffffffffffffffe
=
no
zxid:0xfffffffffffffffe
zxid:0xfffffffffffffffe
test
scala.collection.LinearSeqOptimized$class.foreach(LinearSeqOptimized.
scala.collection.TraversableLike$class.map(TraversableLike.scala:206)
/127.0.0.1
"leader":"0",
0
PartitionStateInfo:
scala.collection.LinearSeqOptimized$class.foreach(LinearSeqOptimized.
scala.collection.TraversableLike$class.map(TraversableLike.scala:206)
scala.collection.immutable.Map$Map1.foreach(Map.scala:105)
7;
"leader":"0",
/127.0.0.1
scala.collection.Iterator$class.foreach(Iterator.scala:631)
scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala
scala.collection.mutable.HashMap.foreach(HashMap.scala:80)
scala.collection.TraversableLike$class.map(TraversableLike.scala:206)
kafka.server.KafkaApis.appendToLocalLog(KafkaApis.scala:192)
0
topic
kafka.producer.BrokerPartitionInfo.warn(BrokerPartitionInfo.scala:27)
scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.
scala.collection.Iterator$class.foreach(Iterator.scala:631)
scala.collection.immutable.Vector.foreach(Vector.scala:36)
kafka.producer.BrokerPartitionInfo.updateInfo(BrokerPartitionInfo.sca
scala.collection.immutable.Stream.foreach(Stream.scala:254)
scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.
scala.collection.immutable.Stream.foreach(Stream.scala:254)
2
there
to
scala.collection.immutable.Map$Map1.foreach(Map.scala:105)
scala.collection.TraversableLike$class.map(TraversableLike.scala:206)
overridden
overridden
is
library-2.8.0.jar;C:\Users\Robert.Withers\.ivy2\cache/org.scala-lang/scala-
j/jars/log4j-1.2.15.jar;C:\Users\Robert.Withers\.ivy2\cache/org.slf4j/slf4j-
0
this
queues
=
0
to
scala.collection.Iterator$class.foreach(Iterator.scala:631)
scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala
scala.collection.mutable.HashMap.foreach(HashMap.scala:80)
=
work,
test,
and
the
windows.
run
input
 
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB