diff --git a/kafka_utils.js b/kafka_utils.js
index 043cfb4..485d681 100644
--- a/kafka_utils.js
+++ b/kafka_utils.js
@@ -1,5 +1,5 @@
 const {Kafka} = require("kafkajs");
-const brokers = []  // TODO:测试kafka
+const brokers = ["172.16.228.89:19092"]  // TODO:测试kafka
 
 /**
  * 
diff --git a/server.js b/server.js
index 155ef25..b89efbe 100644
--- a/server.js
+++ b/server.js
@@ -13,7 +13,7 @@ const utils = require("./utils");
 const {push_data, create_kafka_client} = require("./kafka_utils");
 const topic_message = "whatsapp_test1";
 // const topic_status = "whatsapp_test2";
-const user_iphone = '8615201683893@c.us'; // 当前登陆账号手机 用于判断被踢的是不是自己
+const user_iphone = '8615201683893@c.us'; // TODO:需要修改当前登陆账号手机 用于判断被踢的是不是自己
 
 // 封装部分日志打印内容 新增日期显示
 {
diff --git a/upload_files.js b/upload_files.js
index 4b01d16..4f4e689 100644
--- a/upload_files.js
+++ b/upload_files.js
@@ -1,8 +1,8 @@
 'use strict'
 const axios = require('axios');
 const fs = require('fs');
-const url = ""; // TODO: 上传路径修改
-const dir = "/opt/crawl/whatsapp/whatsapp-wppconnect/sources/"
+const url = "http://10.8.0.10:8081/group1/upload";
+const dir = "/opt/crawl/whatsapp/whatsapp_wppconnect/sources/"