kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Shlomi Hazan <shl...@viber.com>
Subject Re: will adding partitions to existing topic change leadership to existing partitions?
Date Thu, 20 Nov 2014 13:46:42 GMT
Thank you, Guozhang. All clear now.

On Thu, Nov 20, 2014 at 1:29 AM, Guozhang Wang <wangguoz@gmail.com> wrote:

> Hi Shlomi,
>
> By just use "kafka-topics.sh --zookeeper localhost:2181 --alter --topic
> test_topic --partitions 8" the controller will auto assign replicas to the
> newly added partitions, but will not touch the existing ones.
>
> Guozhang
>
> On Mon, Nov 17, 2014 at 11:13 PM, Shlomi Hazan <shlomi@viber.com> wrote:
>
> > Hi Guozhang,
> > Sorry for being too brief but the question referred to adding partitions
> > with the topic tool (without specifying json file).
> > I was not aware of the json file option at all and so my question is
> > dealing with the case the partitions are added like:
> > kafka-topics.sh --zookeeper localhost:2181 --alter --topic test_topic
> > --partitions 8
> > Will then existing partitions be subject to leadership change?
> > 10x
> > Shlomi
> >
> > On Mon, Nov 17, 2014 at 7:04 PM, Guozhang Wang <wangguoz@gmail.com>
> wrote:
> >
> > > Hi Shlomi,
> > >
> > > As long as your json file indicating the partition addition operation
> > does
> > > not touch the existing partitions you should be fine.
> > >
> > > Guozhang
> > >
> > > On Mon, Nov 17, 2014 at 1:08 AM, Shlomi Hazan <shlomi@viber.com>
> wrote:
> > >
> > > > Hi
> > > > I want to add partitions to a running topic,
> > > > and since I use the python producer I will eventually have to restart
> > > > producers to reflect the change.
> > > > the question is if leadership will change for the existing partitions
> > > too,
> > > > forcing me to immediately restart the producers.
> > > > 10x,
> > > > Shlomi
> > > >
> > >
> > >
> > >
> > > --
> > > -- Guozhang
> > >
> >
>
>
>
> --
> -- Guozhang
>

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