kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Guozhang Wang <wangg...@gmail.com>
Subject Re: Add Partition and Rebalancing
Date Wed, 09 Oct 2013 21:04:05 GMT
Hello Shone,

Could you do a git log to see if KAFKA-1075 has been included in your
repository? It was checked in this Monday, so if you checked out the code
earlier than that then the fix will not be included.


On Wed, Oct 9, 2013 at 1:34 PM, Shone Sadler <shone.sadler@gmail.com> wrote:

> Hello,
> I am testing out the AddPartitionCommand in Kafka 8.0 and wanted to verify
> the behavior I am seeing.  Currently, running producers and consumers
> appear unaffected by scaling out of partitions. i.e. Producers do not pick
> up the new partition size for calls to the Partitioner and consumers are
> not rebalanced to pick up the new partitions.  Both producers and consumers
> must be restarted to pick up the new partitions.  Is this expected
> behavior? I did come across the following ticket with respect to consumers
> -> https://issues.apache.org/jira/browse/KAFKA-1075 which is labeled as
> fixed, however I am not seeing the expected behavior.
> Thanks,
> Shone Sadler

-- Guozhang

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