模式查询修改、

@@ -12,12 +12,12 @@ var TOPIC_LOG_STASH = "go_stash_dev"
 var ENABLE_KAFKA_LOG = false
 var ENABLE_KAFKA_LOG = false
 
 
 func init() {
 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("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") != "" {
 	if os.Getenv("ENABLE_KAFKA_LOG") != "" {
 		DISABLE_CREATE_TABLE = true
 		DISABLE_CREATE_TABLE = true
 	}
 	}