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)
