package constant

var (
	// kafka 地址
	KAFKA_HOST = "192.168.0.250:9092,192.168.0.251:9092,192.168.0.252:9092" //"106.75.231.90:9092"
	// kafka  topic log stash
	TOPIC_LOG_STASH = "go_stash_dev" //"pushMessage"
	//  kafka  topic up_block_chain
	TOPIC_UP_BLOCK_CHAIN = "allied_creation_message"
	// 是否启用日志收集 （本地不启用）
	ENABLE_KAFKA_LOG = false
)

func init() {
	KAFKA_HOST = Configurator.DefaultString("KAFKA_HOST", KAFKA_HOST)
	ENABLE_KAFKA_LOG = Configurator.DefaultBool("ENABLE_KAFKA_LOG", ENABLE_KAFKA_LOG)
}