Hi Anuj, The LeaderNotLocalException could be transient:
https://cwiki.apache.org/confluence/display/KAFKA/FAQ#FAQ-WhydoIseelotsofLeadernotlocalexceptionsonthebrokerduringcontrolledshutdown%3F Guozhang On Fri, Sep 13, 2013 at 12:21 AM, Anuj Mehta <mehta.r...@gmail.com> wrote: > Hi > > I am a newbie "Kafka" user. I had 0.8 branch code and trying to run a > simple producer (currently no consumer) from kafka-java-examples on *Window > XP* > > When the producer tries to send a message I get following > > [2013-09-13 12:39:28,244] WARN [KafkaApi-0] Produce request with > correlation id 2 from client on partition [test,0] *failed due to Leader > not local for partition* [test,0] on broker 0 (kafka.server.KafkaApis) > [2013-09-13 12:39:28,431] INFO [KafkaApi-0] Send the close connection > response due to error handling produce request [clientId = , correlationId > = 2, topicAndPartition = [test,0]] with Ack=0 (kafka.server.KafkaApis) > > > Looks like there is a similar issue ( > https://issues.apache.org/jira/browse/KAFKA-876) but it's resolved. > I am attaching server and zookeeper logs for reference. > Please guide. > > Cheers!! > Anuj > http://anuj-mehta.blogspot.com/ > -- -- Guozhang
