diff --git a/app/endpoints/pipeline_endpoint.py b/app/endpoints/pipeline_endpoint.py
index 2d8dcb3..56925a0 100644
--- a/app/endpoints/pipeline_endpoint.py
+++ b/app/endpoints/pipeline_endpoint.py
@@ -1270,7 +1270,7 @@ async def handle_add_friend_notice_async(request: Request,token_id,app_id, wxid,
             # 发送到kafka
             input_wx_content_dialogue_message=[{"type": "text", "text": reply_content}]
             input_message=dialogue_message(wxid,to_contact_wxid,input_wx_content_dialogue_message,True)
-            request.app.state.kafka_service.send_message_async(input_message)
+            await request.app.state.kafka_service.send_message_async(input_message)
             logger.info("发送对话 %s",input_message)
 
         else: