diff --git a/app.py b/app.py
index 3b54afb..6060590 100644
--- a/app.py
+++ b/app.py
@@ -255,6 +255,10 @@ def scan_wx_login_info():
                     print("重连失败，重新登录...")
                     print("发送离线消息到kafka")
                     redis_helper.redis_helper.update_hash_field(k,'status',0)  
+                    
+                    # 推送到kafka
+                    input_message=utils.wx_offline_message(app_id,wxid)
+                    kafka_helper.kafka_client.produce_message(input_message)
 
 
             time.sleep(3)