package constant import ( "os" "strings" ) type KafkaConfig struct { Servers []string `json:"servers"` ConsumerId string `json:"consumerGroup"` } var KafkaCfg KafkaConfig func init() { KafkaCfg = KafkaConfig{ Servers: []string{"127.0.0.1:9092"}, ConsumerId: "partnermg_local", } if os.Getenv("KAFKA_HOST") != "" { kafkaHost := os.Getenv("KAFKA_HOST") KafkaCfg.Servers = strings.Split(kafkaHost, ";") } if os.Getenv("KAFKA_CONSUMER_ID") != "" { consumerId := os.Getenv("KAFKA_CONSUMER_ID") KafkaCfg.ConsumerId = consumerId } } // "192.168.190.136:9092", // "106.52.15.41:9092"