From 7a28116bbe591bd35ca3d2ebef92226d2de8f83b Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=BC=A0=E6=97=AD?= Date: Wed, 24 Feb 2021 09:12:25 +0800 Subject: [PATCH] Fix too much warn log because non-exist retry topic (#681) Co-authored-by: zhangxu16 --- .../rocketmq/console/service/impl/ConsumerServiceImpl.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/main/java/org/apache/rocketmq/console/service/impl/ConsumerServiceImpl.java b/src/main/java/org/apache/rocketmq/console/service/impl/ConsumerServiceImpl.java index 715cbf5..87ddb06 100644 --- a/src/main/java/org/apache/rocketmq/console/service/impl/ConsumerServiceImpl.java +++ b/src/main/java/org/apache/rocketmq/console/service/impl/ConsumerServiceImpl.java @@ -95,7 +95,7 @@ public class ConsumerServiceImpl extends AbstractCommonService implements Consum 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 @@ public class ConsumerServiceImpl extends AbstractCommonService implements Consum 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);