dockerzhang opened a new issue #1179: URL: https://github.com/apache/incubator-inlong/issues/1179
<p> </p> <p>TubeMQ uses the server-side rebalance mode to allocate tasks. At present, the task allocation mode is relatively single, and the implementation of this part is relatively hard-coded, and the readability and maintainability are not good enough.</p> <p>Existing solutions take all the partitions of the topic set subscribed by the consumer group according to the number of consumers in the consumer group, and then extract the partitions at consumer number interval, and allocate the partitions to the corresponding client; if the client or partition has increasing or decreasing, the client with more partitions subscriptions will release the partitions through partial balance, and will be allocated the released partitions to consumers with less or no subscription partitions for balanced consumption.</p> <p>If you are interested, you can try to abstract this piece. At the same time, you can also propose your rebalance plan, which is compatible on the basis of existing rebalance.</p> <i>JIRA link - <a href="https://issues.apache.org/jira/browse/INLONG-590";>[INLONG-590]</a> created by gosonzhang</i> -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
