kafka.go 150 字节

原文件审查历史永久链接

package constant

import "os"

var KAFKA_HOSTS = ""

func init() {
	if os.Getenv("KAFKA_HOSTS") != "" {
		KAFKA_HOSTS = os.Getenv("KAFKA_HOSTS")
	}
}