diff --git a/broker/src/main/java/org/apache/rocketmq/broker/subscription/SubscriptionGroupManager.java b/broker/src/main/java/org/apache/rocketmq/broker/subscription/SubscriptionGroupManager.java index 92dc5e72b25185b833c44ad1281af3282776af2d..bdf2a01efea6b426e0e16370ddd8e6c664d58fe0 100644 --- a/broker/src/main/java/org/apache/rocketmq/broker/subscription/SubscriptionGroupManager.java +++ b/broker/src/main/java/org/apache/rocketmq/broker/subscription/SubscriptionGroupManager.java @@ -184,7 +184,7 @@ public class SubscriptionGroupManager extends ConfigManager { this.dataVersion.nextVersion(); this.persist(); } else { - log.warn("delete subscription group failed, subscription group: {} not exist", old); + log.warn("delete subscription group failed, subscription groupName: {} not exist", groupName); } } } diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/MQClientManager.java b/client/src/main/java/org/apache/rocketmq/client/impl/MQClientManager.java index 6f2c9a38d60252b970fd4ea4ec137653484e4328..f596b8365e758e1b72d66ab6ba74b050927bb365 100644 --- a/client/src/main/java/org/apache/rocketmq/client/impl/MQClientManager.java +++ b/client/src/main/java/org/apache/rocketmq/client/impl/MQClientManager.java @@ -53,8 +53,9 @@ public class MQClientManager { MQClientInstance prev = this.factoryTable.putIfAbsent(clientId, instance); if (prev != null) { instance = prev; + log.warn("Returned Previous MQClientInstance for clientId:[{}]", clientId); } else { - log.warn("Previous MQClientInstance has created for clientId:[{}]", clientId); + log.info("Created new MQClientInstance for clientId:[{}]", clientId); } }