From e975932d4173c038611717a1efc6f8d6cfe03f00 Mon Sep 17 00:00:00 2001 From: ZQKC Date: Fri, 12 May 2023 13:52:26 +0800 Subject: [PATCH] =?UTF-8?q?[Bugfix]=E4=BF=AE=E5=A4=8DPrometheus=E5=BC=80?= =?UTF-8?q?=E6=94=BE=E6=8E=A5=E5=8F=A3=E4=B8=AD=EF=BC=8CPartition=E6=8C=87?= =?UTF-8?q?=E6=A0=87tag=E7=BC=BA=E5=A4=B1=E7=9A=84=E9=97=AE=E9=A2=98(#1013?= =?UTF-8?q?)?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../km/monitor/component/AbstractMonitorSinkService.java | 1 + 1 file changed, 1 insertion(+) 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 f35c5ec6..bbb31647 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 @@ -123,6 +123,7 @@ public abstract class AbstractMonitorSinkService implements ApplicationListener< tagsMap.put(CLUSTER_ID.getName(), p.getClusterPhyId()); tagsMap.put(BROKER_ID.getName(), p.getBrokerId()); tagsMap.put(PARTITION_ID.getName(), p.getPartitionId()); + tagsMap.put(TOPIC.getName(), p.getTopic()); pointList.addAll(genSinkPoint("Partition", p.getMetrics(), p.getTimestamp(), tagsMap)); }