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
