Ahh yes, thanks Guozhang! I thought I did a pull yesterday, but the last change I had was for Kafka-1073 (below). I did a pull again and I now see the change. I'll run my tests again.
Thanks, Shone shonesadler$ git log commit 71ed6ca3368ff38909f502565a4bf0f39e70fc6c Author: Jun Rao <jun...@gmail.com> Date: Mon Oct 7 09:22:12 2013 -0700 kafka-1073; CheckReassignmentStatus is broken; patched by Jun Rao; reviewed by Guozhang Wang, Swa On Wed, Oct 9, 2013 at 5:04 PM, Guozhang Wang <wangg...@gmail.com> wrote: > 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. > > Guozhang > > > On Wed, Oct 9, 2013 at 1:34 PM, Shone Sadler <shone.sad...@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 >