|
|
@ -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 { |
|
|
|