diff --git a/src/main.py b/src/main.py
index e466b6a..7f608f9 100644
--- a/src/main.py
+++ b/src/main.py
@@ -4,6 +4,8 @@ Ejecuta dos APIs en paralelo: Usuarios (puerto 8000) y Reportes (puerto 8001)
 """
 from infrastructure.api.users.app import create_app as create_users_app
 from infrastructure.api.reports.app import create_app as create_reports_app
+from consumers.report_consumer import ReportConsumer
+from consumers.user_consumer import UserConsumer
 from core.config import ConfSettings
 import threading
 import uvicorn
@@ -30,6 +32,15 @@ def run_reports_api():
         log_level=ConfSettings.log_level,
     )
 
+def run_user_consumer():
+    consumer = UserConsumer()
+    consumer.start()
+
+def run_reports_consumer():
+    consumer = ReportConsumer()
+    consumer.start()
+
+
 def run():
     """Inicia ambas APIs en threads separados"""
     print("=" * 60)
@@ -38,9 +49,14 @@ def run():
     
     users_thread = threading.Thread(target=run_users_api, daemon=True, name="Users-API")
     reports_thread = threading.Thread(target=run_reports_api, daemon=True, name="Reports-API")
+    user_consumer_thread = threading.Thread(target=run_user_consumer, daemon=True, name="Users-Consumer")
+    report_consumer_thread = threading.Thread(target=run_reports_consumer, daemon=True, name="Reports-Consumer")
+
     
     users_thread.start()
     reports_thread.start()
+    user_consumer_thread.start()
+    report_consumer_thread.start()
     
     print("\n✓ API de Usuarios ejecutándose en http://0.0.0.0:8000")
     print("✓ API de Reportes ejecutándose en http://0.0.0.0:8001")