[rocketmq-client-go] branch master updated: run RebalanceImmediately with goroutine (#1081)

[dinglei]

This is an automated email from the ASF dual-hosted git repository.

dinglei pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-client-go.git


The following commit(s) were added to refs/heads/master by this push:
     new e22605a  run RebalanceImmediately with goroutine (#1081)
e22605a is described below

commit e22605a82fb4bbb55ce118962e3e250b5c56f482
Author: wenxuwan <wangwenxue....@alibaba-inc.com>
AuthorDate: Mon Jul 24 10:00:10 2023 +0800

    run RebalanceImmediately with goroutine (#1081)
    
    * seperate interface and implement
    
    * fix panic when close tracedispatcher
    
    * Restore rlog/log.go
    
    * Delete default.go
    
    * change RebalanceImmediately with goroutine
---
 consumer/pull_consumer.go | 2 +-
 consumer/push_consumer.go | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/consumer/pull_consumer.go b/consumer/pull_consumer.go
index 6730f07..8af88f1 100644
--- a/consumer/pull_consumer.go
+++ b/consumer/pull_consumer.go
@@ -199,7 +199,7 @@ func (pc *defaultPullConsumer) Start() error {
        }
        pc.client.CheckClientInBroker()
        pc.client.SendHeartbeatToAllBrokerWithLock()
-       pc.client.RebalanceImmediately()
+       go pc.client.RebalanceImmediately()
 
        return err
 }
diff --git a/consumer/push_consumer.go b/consumer/push_consumer.go
index 50eee98..a5b17f6 100644
--- a/consumer/push_consumer.go
+++ b/consumer/push_consumer.go
@@ -244,7 +244,7 @@ func (pc *pushConsumer) Start() error {
        }
        pc.client.CheckClientInBroker()
        pc.client.SendHeartbeatToAllBrokerWithLock()
-       pc.client.RebalanceImmediately()
+       go pc.client.RebalanceImmediately()
 
        return err
 }