Home | About | Sematext search-lucene.com search-hadoop.com
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
 Search Hadoop and all its subprojects:

Switch to Threaded View
Kafka >> mail # user >> Re: LeaderNotAvailableException: reventing the running of kafka-console-producer.bat


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
> -----Original Message-----
> From: Jun Rao [mailto:[EMAIL PROTECTED]]
> Sent: Thursday, April 25, 2013 10:08 PM
> To: [EMAIL PROTECTED]
> Subject: Re: LeaderNotAvailableException: reventing the running of kafka-
> console-producer.bat
>
> Rob,
>
> Are you saying that LeaderNotAvailableException happens only once and
> then
> disappears? That is normal and is different from what happens in
KAFKA-876.
>
> Thanks,
>
> Jun
>
>
> On Thu, Apr 25, 2013 at 8:41 PM, Withers, Robert
> <[EMAIL PROTECTED]>wrote:
>
> > This LeaderNotAvailableException only occurs once now, running kafka 8
> > from a dos shell.  We are following KAFKA-876 closely which we also
> > experience.
> >
> > thanks!
> > rob
> > ________________________________________
> > From: Withers, Robert
> > Sent: Friday, April 19, 2013 6:38 AM
> > To: [EMAIL PROTECTED]
> > Subject: RE: LeaderNotAvailableException: reventing the running of
> > kafka-console-producer.bat
> >
> > Hi Jun,
> >
> > It seems I failed to respond to this post.  My apologies.  I did test a
> > week ago, with the latest 0.8 and it still failed.  The reason I did
wait
> > so long is to get my home machine setup, which I finished today.  At
work
> > we are tearing it up and leaving behind issues so we can get message
> > traffic over kafka-0.7.2 into storm.  We got this working yesterday
> > afternoon..yay!
> >
> > I git cloned kafka (with EGit) and then sbt.bat update and sbt.bat
package.
> >
> > Here is git log results:
> > commit 9ff4e8eb10e0ddd86f257e99d55971a132426605
> > Author: Jay Kreps <[EMAIL PROTECTED]>
> > Date:   Tue Mar 12 11:17:12 2013 -0700
> >
> >     KAFKA-739 Handle null message payloads in messages and in the log
> > cleaner. R
> >
> > commit c1ed12e44ddebe41dc464683e3d7eeb4e6d39a45
> > Author: Jay Kreps <[EMAIL PROTECTED]>
> > Date:   Fri Mar 8 15:07:39 2013 -0800
> >
> >     KAFKA-554 Dynamic per-topic configuration. This patch adds a
> mechanism
> > for s
> >
> > commit 4f2742d60d16f5ba468aa66d2c3ed7aa37479dce
> > Merge: 82b11aa 92ecebe
> > Author: Jun Rao <[EMAIL PROTECTED]>
> > Date:   Sun Mar 3 20:20:41 2013 -0800
> >
> >     merge from 0.8 and resolve conflicts
> >
> > This problem still persists, unfortunately, running
> > kafka-console-consumer.bat and kafka-console-producer.bat.
> >
> > Best,
> > rob
> >
> > ________________________________________
> > From: Jun Rao [[EMAIL PROTECTED]]
> > Sent: Sunday, April 07, 2013 10:59 PM
> > To: [EMAIL PROTECTED]
> > Subject: Re: LeaderNotAvailableException: reventing the running of
> > kafka-console-producer.bat
> >
> > That hash tag points to a commit on Apr 4 and is probably not what you
> > have. Try "git log" on the checkout that builds your binary. If you
can't
> > figure this out, could you try the latest code in the 0.8 branch and see
if
> > the problem still exists?
> >
> > Thanks,
> >
> > Jun
> >
> >
> > On Sat, Apr 6, 2013 at 10:36 AM, Withers, Robert
> <[EMAIL PROTECTED]
> > >wrote:
> >
> > > I am not entirely sure as it has been about a year since I used git.
> > >  Looking in .git\refs\heads\0.8, I have
> > > afecc9f23108b100b27017974b132331d6bab8e6.  .git\HEAD says ref:
> > > refs/heads/0.8.
> > >
> > > If this is not what you need, tell me how I can get you the right
info.
> > >
> > > Thanks,
> > > Rob
> > >
> > >
> > > ________________________________________
> > > From: Jun Rao [[EMAIL PROTECTED]]
> > > Sent: Friday, April 05, 2013 10:10 PM
> > > To: [EMAIL PROTECTED]
> > > Subject: Re: LeaderNotAvailableException: reventing the running of
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.s
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