apache / rocketmq-client-go

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

PushConsumer doesn't rebalance periodically to reassign mq #1057

Open glcrazier opened 1 year ago

glcrazier commented 1 year ago

We add brokers when client is running, but the client doesn't consume messages from new brokers unless we restart the client.

francisoliverlee commented 1 year ago

tried v2.1.2.rc1, it would be ok