-Re: Add Partition and Rebalancing
Guozhang Wang 2013-10-09, 21:04
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 <[EMAIL PROTECTED]> wrote:
> 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.
> Shone Sadler