From 4214ef212f3093c2deec5a3f3285ca3b64a98746 Mon Sep 17 00:00:00 2001 From: "yhydev@outlook.com" Date: Sun, 15 Jun 2025 01:50:57 +0000 Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96=E4=BB=A3=E7=A0=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- comsumer/order.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/comsumer/order.py b/comsumer/order.py index e5b7259..572e756 100644 --- a/comsumer/order.py +++ b/comsumer/order.py @@ -21,7 +21,7 @@ async def start_bn_future_order_consumer(account_id, api_key, api_secret): async def send_msg(msg): logger.info(f"send to kafka: {msg}") - await kafka_service.send_to_kafka("binance_future_order_update", json.dumps(msg)) + await kafka_service.send_to_kafka("binance_future_order_update", json.dumps(msg),key="DEFAULT",send_now=True) logger.info(f"send to kafka success: {msg}")