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
apache · Jul 24, 2023 · e22605a · e22605a
1 parent 533de03
commit e22605a
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git 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
@@ -244,7 +244,7 @@ func (pc *pushConsumer) Start() error {
 	}
 	pc.client.CheckClientInBroker()
 	pc.client.SendHeartbeatToAllBrokerWithLock()
-	pc.client.RebalanceImmediately()
+	go pc.client.RebalanceImmediately()
 
 	return err
 }