rocketmq-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "zhaoziyan (JIRA)" <>
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
             Project: Apache RocketMQ
          Issue Type: Improvement
          Components: rocketmq-client
            Reporter: zhaoziyan
            Assignee: Xiaorui Wang

Consumer Started.
Consumer Started.
Consumer Started.
Consumer Started.
RunHello [i=0, num=281]{/, /, /}
RunHello [i=1, num=250]{/, /}
RunHello [i=2, num=250]{/, /}
RunHello [i=3, num=250]{/, /}

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

View raw message