rocketmq-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "zhaoziyan (JIRA)" <j...@apache.org>
Subject [jira] [Created] (ROCKETMQ-192) Move the client group rebalance to server
Date Thu, 04 May 2017 07:14:04 GMT
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)

Mime
View raw message