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 Plain 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


+
Vadim Keylis 2013-06-28, 17:58
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
I want to clarify that I restarted only one kafka node, all others were
running and did not require restart
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 /10.98.21.112.
> (kafka.network.Processor)
>
>

 
+
David DeMaagd 2013-06-28, 18:25
+
Vadim Keylis 2013-06-28, 18:33
+
David DeMaagd 2013-06-28, 18:47
+
Joel Koshy 2013-06-28, 19:27
+
Vadim Keylis 2013-06-28, 20:40
+
Joel Koshy 2013-06-28, 21:28
+
Jun Rao 2013-06-29, 04:26
+
Vadim Keylis 2013-06-29, 06:27
+
Jun Rao 2013-06-29, 15:46
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