配置修改

@@ -14,9 +14,9 @@ var (
 )
 
 func init() {
-	//if os.Getenv("KAFKA_HOST") != "" {
-	//	POSTGRESQL_HOST = os.Getenv("KAFKA_HOST")
-	//}
+	if os.Getenv("KAFKA_HOST") != "" {
+		KAFKA_HOST = os.Getenv("KAFKA_HOST")
+	}
 	//if os.Getenv("TOPIC_LOG_STASH") != "" {
 	//	POSTGRESQL_PORT = os.Getenv("TOPIC_LOG_STASH")
 	//}