From 00584d7076701b972b02d613d705ace6ae27c39b Mon Sep 17 00:00:00 2001
From: lucas <lu.kai@free-sun.com.cn>
Date: Fri, 29 Aug 2025 14:33:57 +0800
Subject: [PATCH] =?UTF-8?q?update=20=E7=AE=80=E5=8C=96=E4=B8=8D=E5=BF=85?=
 =?UTF-8?q?=E8=A6=81=E7=9A=84=E9=85=8D=E7=BD=AE?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 configFiles/config_安心云告警双控.yaml | 1 -
 consumers/consumerAxySkAlarm.go               | 4 ----
 2 files changed, 5 deletions(-)

diff --git a/configFiles/config_安心云告警双控.yaml b/configFiles/config_安心云告警双控.yaml
index 86ca6d4..e8cb4c6 100644
--- a/configFiles/config_安心云告警双控.yaml
+++ b/configFiles/config_安心云告警双控.yaml
@@ -16,7 +16,6 @@ ioConfig:
       groupId: axy_sk_alarm_inout
       alarmTopic: anxinyun_alarm #推送告警的主题
       topics:
-        - no
       
 monitor:
   cron:  24 * * * *
diff --git a/consumers/consumerAxySkAlarm.go b/consumers/consumerAxySkAlarm.go
index 22e06d1..2213fb1 100644
--- a/consumers/consumerAxySkAlarm.go
+++ b/consumers/consumerAxySkAlarm.go
@@ -71,11 +71,7 @@ func (the *consumerAxySkAlarm) inputInitial() error {
 		GroupId: the.Info.IoConfig.Out.Kafka.GroupId,
 	}
 	the.OutKafka.Initial()
-	for _, inTopic := range the.Info.IoConfig.Out.Kafka.Topics {
-		the.OutKafka.Subscribe(inTopic, the.onData)
-	}
 
-	the.OutKafka.Worker()
 	return nil
 }
 func (the *consumerAxySkAlarm) outputInitial() error {