package constant

var (
	KAFKA_HOST            = "192.168.0.250:9092,192.168.0.251:9092,192.168.0.252:9092"
	TOPIC_TABLE_DATA_SYNC = "allied_creation_metadata_table_sync_notice"
	TOPIC_LOG_STASH       = "go_stash_dev"
	ENABLE_KAFKA_LOG      = false
)

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