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 {