优化代码

2025-06-15 01:50:57 +00:00
parent 739133bf68
commit 4214ef212f
1 changed files with 1 additions and 1 deletions
--- 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}")