[jira] [Created] (ROCKETMQ-192) Move the client group rebalance to server

["zhaoziyan (JIRA)" <ji...@apache.org>]

zhaoziyan created ROCKETMQ-192:
----------------------------------

             Summary: Move the client group rebalance to server 
                 Key: ROCKETMQ-192
                 URL: https://issues.apache.org/jira/browse/ROCKETMQ-192
             Project: Apache RocketMQ
          Issue Type: Improvement
          Components: rocketmq-client
            Reporter: zhaoziyan
            Assignee: Xiaorui Wang
         Attachments: TestConsumerQueue.java

Consumer Started.
Consumer Started.
Consumer Started.
Consumer Started.
RunHello [i=0, num=281]{/192.168.185.172:10911@2=31, /192.168.185.172:10911@0=125, /192.168.185.172:10911@1=125}
RunHello [i=1, num=250]{/192.168.185.172:10911@2=125, /192.168.185.172:10911@3=125}
RunHello [i=2, num=250]{/192.168.186.131:10911@1=125, /192.168.186.131:10911@0=125}
RunHello [i=3, num=250]{/192.168.186.131:10911@3=125, /192.168.186.131:10911@2=125}
SIZE=1000
重复31

here is my test，the Test show the client may consume the queue in some case. because of the current Group rebalance is doing by the consumer side,some case , the consumer may have diffent view of All Consumer ids.

for Example: the consumer id 1 see have 3 consumers,but the consumer id 2 only see 2 consumers, so the same queue may hold by two consumer.

Kakfa 0.8.2 to 0.9 have redesign the client, move the Group rebalance to server side, have we need also move the Rebalance to server size ??





--
This message was sent by Atlassian JIRA
(v6.3.15#6346)