kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Xiaoyu Wang <xw...@rocketfuel.com>
Subject Re: Producer can writes to a follower during preferred lead election?
Date Sun, 07 Dec 2014 14:45:39 GMT
Thanks Gwen. This answers my question.

On Sun, Dec 7, 2014 at 5:44 AM, Gwen Shapira <gshapira@cloudera.com> wrote:

> If you write to a non-leader partition, I'd expect you'd get
> NotLeaderForPartitionException (thrown by
> Partition.appendMessagesToLeader).
> This will get sent to the producer as error code 6.
>
> I don't see anything special in the producer side to handle this
> specific (although I'd expect a forced metadata refresh and then a
> re-send).
>
> Gwen
>
> On Sat, Dec 6, 2014 at 6:46 PM, Xiaoyu Wang <xwang@rocketfuel.com> wrote:
> > Hello,
> >
> > I am looking at producer code and found that producer updates its
> > broker/partition info under the two conditions
> >
> >    1. has reached the topicMetadataRefreshInterval
> >    2. failed sending message, before retry
> >
> > So, assume we have broker A and B, B is the current lead and A is the
> > preferred lead and a producer is publishing to B. If someone execute
> > preferred lead election command now, A will become the new lead and the
> > producer won't know the lead is now A and will still writes to B until
> the
> > metadata refresh interval has been reached. Is this correct? Or did I did
> > miss anything.
> >
> >
> > Thanks.
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message