From 6b10ece0e3e42430f8d4aae51ce988dfc1ec7e46 Mon Sep 17 00:00:00 2001 From: 18209 Date: Mon, 21 Jul 2025 10:20:04 +0800 Subject: [PATCH] =?UTF-8?q?=E7=9F=A5=E7=89=A9=E4=BA=91=E5=91=8A=E8=AD=A6?= =?UTF-8?q?=E4=B8=BB=E9=A2=98=E4=BB=8E=E4=BC=98=E5=8C=96=E6=88=90=E5=8A=A8?= =?UTF-8?q?=E6=80=81=E8=8E=B7=E5=8F=96=E4=B8=BB=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- consumers/consumerSavoirTheme.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/consumers/consumerSavoirTheme.go b/consumers/consumerSavoirTheme.go index d0f5f77..3c34be0 100644 --- a/consumers/consumerSavoirTheme.go +++ b/consumers/consumerSavoirTheme.go @@ -150,7 +150,7 @@ func (the *consumerSavoirTheme) judgeOffline() { //拿到当前es最后一条数据和当前数据库的配置之后去查是否产生告警 StrValue := "80040003" alarmQueryStr := the.getEsAlarmValueStr(gap.StructId, StrValue) - allAlarmThemes, err := the.OutEs.SearchAlarmThemeData("native_alarms", alarmQueryStr) + allAlarmThemes, err := the.OutEs.SearchAlarmThemeData(the.Info.IoConfig.In.Kafka.AlarmTopic, alarmQueryStr) log.Printf("allAlarmThemes----- > %s", allAlarmThemes) if err != nil { log.Printf("查询es 异常")