From e22605a82fb4bbb55ce118962e3e250b5c56f482 Mon Sep 17 00:00:00 2001 From: wenxuwan Date: Mon, 24 Jul 2023 10:00:10 +0800 Subject: [PATCH] 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 6730f074..8af88f19 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 50eee984..a5b17f66 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 }