From 8ffe7e71018d832e6917455446c650ee7d66a9b3 Mon Sep 17 00:00:00 2001 From: zengqiao Date: Mon, 14 Nov 2022 10:58:01 +0800 Subject: [PATCH] =?UTF-8?q?[Bugfix]=E4=BF=AE=E5=A4=8DPrometheus=E4=B8=ADGr?= =?UTF-8?q?oup=E9=83=A8=E5=88=86=E6=8C=87=E6=A0=87=E7=BC=BA=E5=B0=91?= =?UTF-8?q?=E7=9A=84=E9=97=AE=E9=A2=98(#756)?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../monitor/component/AbstractMonitorSinkService.java | 10 ++++++++++ 1 file changed, 10 insertions(+) diff --git a/km-extends/km-monitor/src/main/java/com/xiaojukeji/know/streaming/km/monitor/component/AbstractMonitorSinkService.java b/km-extends/km-monitor/src/main/java/com/xiaojukeji/know/streaming/km/monitor/component/AbstractMonitorSinkService.java index b2ca9283..47288792 100644 --- a/km-extends/km-monitor/src/main/java/com/xiaojukeji/know/streaming/km/monitor/component/AbstractMonitorSinkService.java +++ b/km-extends/km-monitor/src/main/java/com/xiaojukeji/know/streaming/km/monitor/component/AbstractMonitorSinkService.java @@ -139,11 +139,21 @@ public abstract class AbstractMonitorSinkService implements ApplicationListener< for(GroupMetrics g : groupMetrics){ if(g.isBGroupMetric()){ + // Group 指标 Map tagsMap = new HashMap<>(); tagsMap.put(CLUSTER_ID.getName(), g.getClusterPhyId()); tagsMap.put(CONSUMER_GROUP.getName(), g.getGroup()); pointList.addAll(genSinkPoint("Group", g.getMetrics(), g.getTimestamp(), tagsMap)); + } else { + // Group + Topic + Partition指标 + Map tagsMap = new HashMap<>(); + tagsMap.put(CLUSTER_ID.getName(), g.getClusterPhyId()); + tagsMap.put(CONSUMER_GROUP.getName(), g.getGroup()); + tagsMap.put(TOPIC.getName(), g.getTopic()); + tagsMap.put(PARTITION_ID.getName(), g.getPartitionId()); + + pointList.addAll(genSinkPoint("Group_Topic_Partition", g.getMetrics(), g.getTimestamp(), tagsMap)); } }