search

apache / rocketmq-client-go

Apache RocketMQ go client
https://rocketmq.apache.org/
Apache License 2.0
1.29k stars 415 forks source link

Unable to rebalance after adding queues #1056

Closed lvxiao1 closed 1 year ago

lvxiao1 commented 1 year ago

Client version 2.1.0 rocketmq version 4.4.0 os windows10

During application runtime, queues were added to the topic, but the client did not rebalance, requiring a service restart.

image

lvxiao1 commented 1 year ago

Failed to reproduce and work normal in:

Client version: master branch in https://github.com/apache/rocketmq-client-go
RocketMQ version: 5.1.0
OS: Windows 10

image

Try upgrade client or RocketMQ version?👀

I have found the issue, mainly because when the consumer and producer have the same topic, the consumer fails to update the topic. fix: https://github.com/apache/rocketmq-client-go/pull/1059