apache / rocketmq

Apache RocketMQ is a cloud native messaging and streaming platform, making it simple to build event-driven applications.
https://rocketmq.apache.org/
Apache License 2.0
21.13k stars 11.64k forks source link

[Enhancement] Remove lock mq step in broadcasting mode rebalancing #8772

Open redlsz opened 2 days ago

redlsz commented 2 days ago

Before Creating the Enhancement Request

Summary

Remove lock mq step in broadcasting mode rebalancing.

Motivation

image image

When starts multiple orderly broadcasting mode consumers, some of them cannot consume for a period time after startup, caused by lock mq failure. This mq lock mechanism, designed for clustering consumption mode, is not applicable and unnecessary in broadcasting consumption mode.

当启动多个广播模式的顺序消费者时,一些消费者启动后一段时间内无法正常消费,原因是重平衡时对队列加锁失败了。队列加锁机制是为集群消费模式而设计的,广播消费模式下不适用也没有必要。

Describe the Solution You'd Like

Remove lock mq step in broadcasting mode rebalancing.

Describe Alternatives You've Considered

/

Additional Context

No response