Jun. Yes. I am using 0.8.0-beta1.
On Fri, Jun 28, 2013 at 9:26 PM, Jun Rao <jun...@gmail.com> 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 <vkeylis2...@gmail.com
> >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 /
> 10.98.21.112.
> > (kafka.network.Processor)
> >
>
