Kafka, mail # user - Re: produce request failed: due to Leader not local for partition - 2013-06-25, 05:14
Solr & Elasticsearch trainings in New York & San Francisco [more info][hide]
 Search Hadoop and all its subprojects:

Switch to Plain View
+
Jason Rosenberg 2013-06-23, 08:45
+
Sriram Subramanian 2013-06-23, 08:55
+
Jason Rosenberg 2013-06-23, 09:04
+
Jun Rao 2013-06-24, 03:23
+
Jason Rosenberg 2013-06-24, 07:23
+
Joel Koshy 2013-06-24, 08:57
+
Jun Rao 2013-06-24, 14:50
+
Joel Koshy 2013-06-24, 15:45
+
Jason Rosenberg 2013-06-24, 21:50
+
Jun Rao 2013-06-25, 04:05
+
Jason Rosenberg 2013-06-25, 04:50
+
Jun Rao 2013-06-25, 05:01
Copy link to this message
-
Re: produce request failed: due to Leader not local for partition
Jun,

To be clear, this whole discussion was started, because I am clearly seeing
"failed due to Leader not local" on the last broker restarted, after all
the controlled shutting down has completed and all brokers restarted.

This leads me to believe that a client made a meta data request and found
out that server A was the leader for it's partition, and then server A was
restarted, and then the client makes repeated producer requests to server
A, without encountering a broken socket.  Thus, I'm not sure it's correct
that the socket is invalidated in that case after a restart.

Alternatively, could it be that the client (which sends messages to
multiple topics), gets metadata updates for multiple topics, but doesn't
attempt to send a message to topicX until after the leader has changed and
server A has been restarted.  In this case, if it's the first time the
producer sends to topicX, does it only then create a new socket?

Jason
On Mon, Jun 24, 2013 at 10:00 PM, Jun Rao <[EMAIL PROTECTED]> wrote:
 
+
Jason Rosenberg 2013-06-25, 05:25
+
Jason Rosenberg 2013-06-25, 05:53
+
Jason Rosenberg 2013-06-29, 13:22
+
Jun Rao 2013-07-01, 04:33
+
Ivan Balashov 2015-06-17, 00:55
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