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 >> Fetch request with correlation id 1171437 from client ReplicaFetcherThread-0-1 on partition [meetme,0] failed due to Leader not local for partition


Copy link to this message
-
Re: Fetch request with correlation id 1171437 from client ReplicaFetcherThread-0-1 on partition [meetme,0] failed due to Leader not local for partition
Is that warning transient? If not, take a look at the state-change.log.
This should include all the leaderAndIsr requests. See the leader received
by this broker matches what's determined by the controller (in the
controller.log in the controller broker).

Thanks,

Jun
On Fri, Jun 28, 2013 at 11:26 PM, Vadim Keylis <[EMAIL PROTECTED]>wrote:

> Jun. Yes. I am using 0.8.0-beta1.
>
>
> On Fri, Jun 28, 2013 at 9:26 PM, Jun Rao <[EMAIL PROTECTED]> wrote:
>
> > In this case. the warning is for the fetch request from the replica, not
> > regular consumers. I assume this the log for the restarted broker. Is
> this
> > transient? Are you using 0.8.0-beta1?
> >
> > Thanks,
> >
> > Jun
> >
> >
> > On Fri, Jun 28, 2013 at 10:57 AM, Vadim Keylis <[EMAIL PROTECTED]
> > >wrote:
> >
> > > Good morning. I have a cluster of 3 kafka nodes. They were both running
> > at
> > > the time. I need it to make configuration change in the property file
> and
> > > restart kafka. I have not broker shutdown tool, but simple used pkill
> > -TERM
> > > -u ${KAFKA_USER} -f kafka.Kafka. That suddenly cause the  exception.
> How
> > to
> > > avoid this issue in the future? What's the right way to shutdown kafka
> to
> > > prevent Not Leder Exception
> > >
> > > Thanks so much in advance,
> > > Vadim
> > >
> > >
> > >
> > > [2013-06-28 10:46:53,281] WARN [KafkaApi-1] Fetch request with
> > correlation
> > > id 1171435 from client ReplicaFetcherThread-0-1 on partition [meetme,0]
> > > failed due to Leader not local for partition [meetme,0] on broker 1
> > > (kafka.server.KafkaApis)
> > > [2013-06-28 10:46:53,282] WARN [KafkaApi-1] Fetch request with
> > correlation
> > > id 1171436 from client ReplicaFetcherThread-0-1 on partition [meetme,0]
> > > failed due to Leader not local for partition [meetme,0] on broker 1
> > > (kafka.server.KafkaApis)
> > > [2013-06-28 10:46:53,448] WARN [ReplicaFetcherThread-0-2], error for
> > > partition [meetme,0] to broker 2 (kafka.server.ReplicaFetcherThread)
> > > kafka.common.NotLeaderForPartitionException
> > >         at
> sun.reflect.GeneratedConstructorAccessor2.newInstance(Unknown
> > > Source)
> > >         at
> > >
> > >
> >
> sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:27)
> > >         at
> > java.lang.reflect.Constructor.newInstance(Constructor.java:513)
> > >         at java.lang.Class.newInstance0(Class.java:355)
> > >         at java.lang.Class.newInstance(Class.java:308)
> > >         at
> kafka.common.ErrorMapping$.exceptionFor(ErrorMapping.scala:70)
> > >         at
> > >
> > >
> >
> kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$4$$anonfun$apply$5.apply(AbstractFetcherThread.scala:157)
> > >         at
> > >
> > >
> >
> kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$4$$anonfun$apply$5.apply(AbstractFetcherThread.scala:157)
> > >         at kafka.utils.Logging$class.warn(Logging.scala:88)
> > >         at
> > kafka.utils.ShutdownableThread.warn(ShutdownableThread.scala:23)
> > >         at
> > >
> > >
> >
> kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$4.apply(AbstractFetcherThread.scala:156)
> > >         at
> > >
> > >
> >
> kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$4.apply(AbstractFetcherThread.scala:112)
> > >         at
> > > scala.collection.immutable.HashMap$HashMap1.foreach(HashMap.scala:178)
> > >         at
> > >
> scala.collection.immutable.HashMap$HashTrieMap.foreach(HashMap.scala:347)
> > >         at
> > >
> > >
> >
> kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:112)
> > >         at
> > >
> kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
> > >         at
> > kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
> > > [2013-06-28 10:46:53,476] INFO Closing socket connection to /
> > 10.98.21.112.
> > > (kafka.network.Processor)
> > > [2013-06-28 10:46:53,686] INFO Closing socket connection to /

 
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