diff --git a/app/integrations/kafka.py b/app/integrations/kafka.py
index 23b333c..a30a01e 100644
--- a/app/integrations/kafka.py
+++ b/app/integrations/kafka.py
@@ -146,7 +146,7 @@ class KafkaIntegration:
         logger.info(f"Calling collect_loan service with message: {message}")
 
         try:
-            response = SimbrellaClient.collect_loan(message)
+            response = SimbrellaClient.collect_loan_user_initiated(message)
             logger.info(
                 f"Successfully sent message to collect_loan service: {response}"
             )
diff --git a/app/integrations/simbrella.py b/app/integrations/simbrella.py
index 84c34b7..b4cbd36 100644
--- a/app/integrations/simbrella.py
+++ b/app/integrations/simbrella.py
@@ -180,6 +180,7 @@ class SimbrellaClient:
     @staticmethod
     def collect_loan_user_initiated(data):
         # InitiatedBy = USER_INITIATED
+        logger.info(f"Calling CollectLoan collect_loan_user_initiated ******* endpoint with data: {data}")
         return SimbrellaClient._collect_loan(data)
 
     @staticmethod