How about your zookeeper cluster？ Best Regards Jerry -----Original Message----- From: "Yu, Libo"<libo...@citi.com> To: "'users@kafka.apache.org'"<users@kafka.apache.org>; Cc: Sent: 2013-11-15 (星期五) 01:23:06 Subject: Leader not local
Hi team, I saw this line within a long time span in our logs for the same topic and partition. [2013-11-14 11:13:41,647] WARN [KafkaApi-1] Produce request with correlation id 529240 from client on partition [mytopic,2] failed due to Leader not local for partition [mytopic,2] on broker 1 (kafka.server.KafkaApis) Why can't the producer find out the broker it is publishing to is not the broker in this case? I believe it should find it out and publish to the leader broker. Regards, Libo
