kafka日志

@@ -19,6 +19,6 @@ func init() {
 		POSTGRESQL_PORT = os.Getenv("TOPIC_LOG_STASH")
 	}
 	if os.Getenv("ENABLE_KAFKA_LOG") != "" {
-		DISABLE_CREATE_TABLE = true
+		ENABLE_KAFKA_LOG = true
 	}
 }