commit ab8a1f03417a54393558a192e654484fa44c9f36
author 张旭 <maixiaohai00@gmail.com> Wed Feb 24 09:12:25 2021 +0800
committer GitHub <noreply@github.com> Wed Feb 24 09:12:25 2021 +0800
tree 00fdac81aa9bb38b25fea0d41c7d3e4051fef6af
parent cc0ed4f3434c157e9c88ac80f677c0b224e7c1e3

Fix too much warn log because non-exist retry topic (#681)

Co-authored-by: zhangxu16 <zhangxu16@xiaomi.com>

rocketmq-console/src/main/java/org/apache/rocketmq/console/service/impl/ConsumerServiceImpl.java

diff --git a/rocketmq-console/src/main/java/org/apache/rocketmq/console/service/impl/ConsumerServiceImpl.java b/rocketmq-console/src/main/java/org/apache/rocketmq/console/service/impl/ConsumerServiceImpl.java
index 715cbf5..87ddb06 100644
--- a/rocketmq-console/src/main/java/org/apache/rocketmq/console/service/impl/ConsumerServiceImpl.java
+++ b/rocketmq-console/src/main/java/org/apache/rocketmq/console/service/impl/ConsumerServiceImpl.java
@@ -95,7 +95,7 @@
                 consumeStats = mqAdminExt.examineConsumeStats(consumerGroup);
             }
             catch (Exception e) {
-                logger.warn("examineConsumeStats exception, " + consumerGroup, e);
+                logger.warn("examineConsumeStats exception to consumerGroup {}, response [{}]", consumerGroup, e.getMessage());
             }
 
             ConsumerConnection consumerConnection = null;
@@ -103,7 +103,7 @@
                 consumerConnection = mqAdminExt.examineConsumerConnectionInfo(consumerGroup);
             }
             catch (Exception e) {
-                logger.warn("examineConsumerConnectionInfo exception, " + consumerGroup, e);
+                logger.warn("examineConsumeStats exception to consumerGroup {}, response [{}]", consumerGroup, e.getMessage());
             }
 
             groupConsumeInfo.setGroup(consumerGroup);