Hi Anuj,
Could you describe how to reproduce this? And will this exception result in
message failed to send in the end? I still think this is transient, as the
producer retries in the future and as the leader be elected, the messages
should be sent eventually.
Guozhang
On Mon, Sep 16, 2013 at 7
Anuj,
If you look at Partition.makeLeader(), leaderReplicaOpt gets updated to the
latest leader.
As Guozhang pointed out, this error should be transient.
Thanks,
Neha
On Sep 16, 2013 5:22 AM, "Anuj Mehta" wrote:
> Hi Guozhang
>
> Thanks for your reply. The problem is not transient in my case.
Hi Guozhang
Thanks for your reply. The problem is not transient in my case. I tried
debugging the issue and find problem in following code snippet (please
correct me if I am wrong)
As part of code for handling ProducerRequest (from KafkaApis) following
code is executed
val partitionOpt = replic
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 wrote:
> Hi
>
> I am a newbie "Kafka" user.
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 fro
