kafka.go 221 字节 原文件 审查 历史 永久链接 1 2 3 4 5 6 7 8 9 10 11 12 13 package constant import "os" const KAFKA_HOSTS = "192.168.139.129:9092" const PUSH_MESSAGE_TOPIC = "pushMessage" func init() { if os.Getenv("KAFKA_HOSTS") != "" { POSTGRESQL_DB_NAME = os.Getenv("KAFKA_HOSTS") } }