diff --git a/config/configStruct.go b/config/configStruct.go index 0756601..c67d577 100644 --- a/config/configStruct.go +++ b/config/configStruct.go @@ -18,9 +18,9 @@ type MqttConfig struct { Topics []string `json:"topics" yaml:"topics"` } type KafkaConfig struct { - Brokers []string `json:"brokers"` - GroupId string `json:"groupId"` - Topics []string `json:"topics"` + Brokers []string `json:"brokers" yaml:"brokers"` + GroupId string `json:"groupId" yaml:"groupId"` + Topics []string `json:"topics" yaml:"topics"` } type EsConfig struct { diff --git a/consumers/HBJCAS/config.go b/consumers/HBJCAS/config.go index 6ca316c..f2b10ee 100644 --- a/consumers/HBJCAS/config.go +++ b/consumers/HBJCAS/config.go @@ -20,7 +20,7 @@ type ioConfig struct { } type In struct { Http config.HttpConfig `yaml:"http"` - Kafka config.KafkaConfig `json:"kafka"` + Kafka config.KafkaConfig `yaml:"kafka"` } type Out struct {