(rocketmq) branch develop updated: [ISSUE #8164] Log more accurate for the MQClientInstance#doRebalance (#8165)

[zhouxzhan]

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

zhouxzhan pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/develop by this push:
     new 0ad0244fe5 [ISSUE #8164] Log more accurate for the 
MQClientInstance#doRebalance (#8165)
0ad0244fe5 is described below

commit 0ad0244fe504d9e20a15e83222826f1172bdc4b3
Author: hiyo <77013030+miles-...@users.noreply.github.com>
AuthorDate: Mon May 20 10:47:59 2024 +0800

    [ISSUE #8164] Log more accurate for the MQClientInstance#doRebalance (#8165)
---
 .../java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java
 
b/client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java
index 1ff35a00d1..b4ebf69273 100644
--- 
a/client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java
+++ 
b/client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java
@@ -1070,7 +1070,7 @@ public class MQClientInstance {
                         balanced = false;
                     }
                 } catch (Throwable e) {
-                    log.error("doRebalance exception", e);
+                    log.error("doRebalance for consumer group [{}] exception", 
entry.getKey(), e);
                 }
             }
         }