package constant

import "os"

// kafka 地址
var KAFKA_HOSTS = ""

// kafka  topic log stash
var TOPIC_LOG_STASH = "go_stash_dev"

// 是否启用日志收集 （本地不启用）
var ENABLE_KAFKA_LOG = false

func init() {
	if os.Getenv("KAFKA_HOSTS") != "" {
		KAFKA_HOSTS = os.Getenv("KAFKA_HOSTS")
	}
	if os.Getenv("TOPIC_LOG_STASH") != "" {
		POSTGRESQL_PORT = os.Getenv("TOPIC_LOG_STASH")
	}
	if os.Getenv("ENABLE_KAFKA_LOG") != "" {
		DISABLE_CREATE_TABLE = true
	}
}