diff --git a/app/endpoints/pipeline_endpoint.py b/app/endpoints/pipeline_endpoint.py
index 803ad94..e692afc 100644
--- a/app/endpoints/pipeline_endpoint.py
+++ b/app/endpoints/pipeline_endpoint.py
@@ -1067,7 +1067,7 @@ async def handle_add_friend_notice_async(request: Request,token_id,app_id, wxid,
 
             input_wx_content_dialogue_message=[{"type": "text", "text": msg_content}]
             input_message=dialogue_message(to_contact_wxid,wxid,input_wx_content_dialogue_message)
-            await request.app.state.gewe_service.send_message_async(input_message)
+            await request.app.state.kafka_service.send_message_async(input_message)
             logger.info("发送对话 %s",input_message)
 
             callback_to_user=to_contact_wxid