From decf761dcee3646a0884f1386f5e41e6ed7abc9e Mon Sep 17 00:00:00 2001 From: "steve.gao" Date: Tue, 11 Feb 2025 16:48:38 +0800 Subject: [PATCH] =?UTF-8?q?fix=EF=BC=9A=E4=BF=AE=E5=A4=8Dgo-fast=E3=80=81k?= =?UTF-8?q?afka=E5=9C=B0=E5=9D=80=E4=BB=A5=E5=8F=8A=E8=B5=84=E6=BA=90?= =?UTF-8?q?=E4=BF=9D=E5=AD=98=E4=BD=8D=E7=BD=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- kafka_utils.js | 2 +- server.js | 2 +- upload_files.js | 4 ++-- 3 files changed, 4 insertions(+), 4 deletions(-) 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/"