jiulinxiri/rocketmq-dashboard
1
0
Fork 0
mirror of https://github.com/apache/rocketmq-dashboard.git synced 2025-09-11 03:49:06 +08:00
Code Issues Packages Projects Releases Wiki Activity

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

Browse Source 
Co-authored-by: zhangxu16 <zhangxu16@xiaomi.com>
This commit is contained in:
张旭
2021-02-24 09:12:25 +08:00
committed by GitHub
parent 0d15d6b6e4
commit 7a28116bbe
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/main/java/org/apache/rocketmq/console/service/impl/ConsumerServiceImpl.java
View File

@@ -95,7 +95,7 @@ public class ConsumerServiceImpl extends AbstractCommonService implements Consum
consumeStats = mqAdminExt.examineConsumeStats(consumerGroup); consumeStats = mqAdminExt.examineConsumeStats(consumerGroup);
} }
catch (Exception e) { catch (Exception e) {
logger.warn("examineConsumeStats exception, " + consumerGroup, e); logger.warn("examineConsumeStats exception to consumerGroup {}, response [{}]", consumerGroup, e.getMessage());
} }
ConsumerConnection consumerConnection = null; ConsumerConnection consumerConnection = null;
@@ -103,7 +103,7 @@ public class ConsumerServiceImpl extends AbstractCommonService implements Consum
consumerConnection = mqAdminExt.examineConsumerConnectionInfo(consumerGroup); consumerConnection = mqAdminExt.examineConsumerConnectionInfo(consumerGroup);
} }
catch (Exception e) { catch (Exception e) {
logger.warn("examineConsumerConnectionInfo exception, " + consumerGroup, e); logger.warn("examineConsumeStats exception to consumerGroup {}, response [{}]", consumerGroup, e.getMessage());
} }
groupConsumeInfo.setGroup(consumerGroup); groupConsumeInfo.setGroup(consumerGroup);