run RebalanceImmediately with goroutine

What is the purpose of the change

When the application cluster is published, consumer will receive many notification:

RebalanceIfNotPaused will run with lock.

So consumer start spend long time.

The java sdk implement like this, only send notify:

Brief changelog

Verifying this change

XXXX

Follow this checklist to help us incorporate your contribution quickly and easily. Notice, it would be helpful if you could finish the following 5 checklist(the last one is not necessary)before request the community to review your PR.

[x] Make sure there is a Github issue filed for the change (usually before you start working on it). Trivial changes like typos do not require a Github issue. Your pull request should address just this issue, without pulling in other changes - one PR resolves one issue.
[x] Format the pull request title like [ISSUE #123] Fix UnknownException when host config not exist. Each commit in the pull request should have a meaningful subject line and body.
[x] Write a pull request description that is detailed enough to understand what the pull request does, how, and why.
[x] Write necessary unit-test(over 80% coverage) to verify your logic correction, more mock a little better when a cross-module dependency exists.
[ ] If this contribution is large, please file an Apache Individual Contributor License Agreement.

================== WARNING: DATA RACE Read at 0x00c000baa5d8 by goroutine 904: github.com/apache/rocketmq-client-go/v2/internal.(SubscriptionData).Clone() /Users/tu/go/pkg/mod/github.com/apache/rocketmq-client-go/v2@v2.1.2-0.20230803074138-7eedaf948c60/internal/model.go:70 +0x1d4 github.com/apache/rocketmq-client-go/v2/consumer.(defaultConsumer).SubscriptionDataList.func1() /Users/tu/go/pkg/mod/github.com/apache/rocketmq-client-go/v2@v2.1.2-0.20230803074138-7eedaf948c60/consumer/consumer.go:457 +0x6c sync.(Map).Range() /usr/local/go/src/sync/map.go:476 +0x2d8 github.com/apache/rocketmq-client-go/v2/consumer.(defaultConsumer).SubscriptionDataList() /Users/tu/go/pkg/mod/github.com/apache/rocketmq-client-go/v2@v2.1.2-0.20230803074138-7eedaf948c60/consumer/consumer.go:456 +0xf4 github.com/apache/rocketmq-client-go/v2/consumer.(pushConsumer).SubscriptionDataList() /Users/tu/go/pkg/mod/github.com/apache/rocketmq-client-go/v2@v2.1.2-0.20230803074138-7eedaf948c60/consumer/push_consumer.go:351 +0x4c github.com/apache/rocketmq-client-go/v2/internal.(rmqClient).UpdateTopicRouteInfo.func2() /Users/tu/go/pkg/mod/github.com/apache/rocketmq-client-go/v2@v2.1.2-0.20230803074138-7eedaf948c60/internal/client.go:706 +0x90 sync.(Map).Range() /usr/local/go/src/sync/map.go:476 +0x2d8 github.com/apache/rocketmq-client-go/v2/internal.(rmqClient).UpdateTopicRouteInfo() /Users/tu/go/pkg/mod/github.com/apache/rocketmq-client-go/v2@v2.1.2-0.20230803074138-7eedaf948c60/internal/client.go:704 +0x3d8 github.com/apache/rocketmq-client-go/v2/internal.(rmqClient).Start.func1.2.1() /Users/tu/go/pkg/mod/github.com/apache/rocketmq-client-go/v2@v2.1.2-0.20230803074138-7eedaf948c60/internal/client.go:447 +0x34 github.com/apache/rocketmq-client-go/v2/internal.(rmqClient).Start.func1.2() /Users/tu/go/pkg/mod/github.com/apache/rocketmq-client-go/v2@v2.1.2-0.20230803074138-7eedaf948c60/internal/client.go:457 +0x38c github.com/apache/rocketmq-client-go/v2/primitive.WithRecover() /Users/tu/go/pkg/mod/github.com/apache/rocketmq-client-go/v2@v2.1.2-0.20230803074138-7eedaf948c60/primitive/base.go:100 +0x50 github.com/apache/rocketmq-client-go/v2/internal.(*rmqClient).Start.func1.7() /Users/tu/go/pkg/mod/github.com/apache/rocketmq-client-go/v2@v2.1.2-0.20230803074138-7eedaf948c60/internal/client.go:444 +0x3c

Previous write at 0x00c000baa5d8 by goroutine 907: github.com/apache/rocketmq-client-go/v2/consumer.(pushConsumer).messageQueueChanged() /Users/tu/go/pkg/mod/github.com/apache/rocketmq-client-go/v2@v2.1.2-0.20230803074138-7eedaf948c60/consumer/push_consumer.go:505 +0x30c github.com/apache/rocketmq-client-go/v2/consumer.(pushConsumer).messageQueueChanged-fm()

:1 +0xb8 github.com/apache/rocketmq-client-go/v2/consumer.(*defaultConsumer).doBalance.func1() /Users/tu/go/pkg/mod/github.com/apache/rocketmq-client-go/v2@v2.1.2-0.20230803074138-7eedaf948c

apache / rocketmq-client-go