diff --git a/app/integrations/kafka.py b/app/integrations/kafka.py
index 8a35a7c..a974343 100644
--- a/app/integrations/kafka.py
+++ b/app/integrations/kafka.py
@@ -51,7 +51,7 @@ class KafkaIntegration:
         :return: The message value (decoded) or None if no message is received
         """
         consumer = KafkaIntegration._get_consumer()
-        # consumer.subscribe(["LOAN_REPAYMENT"])
+        # consumer.subscribe(["PROCESS_PAYMENT"])
         # consumer.subscribe([topic])
         consumer.subscribe(['LOAN_REPAYMENT', 'PROCESS_PAYMENT'])
 
diff --git a/app/integrations/simbrella.py b/app/integrations/simbrella.py
index 073e7d2..f125d52 100644
--- a/app/integrations/simbrella.py
+++ b/app/integrations/simbrella.py
@@ -14,16 +14,6 @@ class SimbrellaClient:
         logger.info(f"BANK_CALL_BASE_URL = {SimbrellaClient.BANK_CALL_BASE_URL}")
         logger.info(f"Calling Disbursement endpoint with data: {data}")
 
-        data={
-            "requestId": "RQID1743987402764",
-            "transactionId": "24",
-            "customerId": "CN437703",
-            "accountId": "ACN2167485",
-            "msisdn": "3451342",
-            "resultCode": "00",
-            "resultDescription": "Successful"
-        }
-
         disbursement_data ={
             "requestId": data['requestId'],
             "transactionId": data['transactionId'],
@@ -61,10 +51,10 @@ class SimbrellaClient:
         collect_loan_data = {
             "transactionId": "T002",
             "fbnTransactionId": "FBN20231123",
-            "debtId": "273194670",
-            "customerId": "CN621868",
+            "debtId": data['debtId'],
+            "customerId": data['customerId'],
             "accountId": "2017821799",
-            "productId": "101",
+            "productId": data['productId'],
             "collectAmount": 80000,
             "penalCharge": 0,
             "collectionMethod": 1,
@@ -86,16 +76,16 @@ class SimbrellaClient:
 
     @staticmethod
     def verify_transaction(data):
-        api_url = f"{SimbrellaClient.BANK_CALL_BASE_URL}/TransactionVerify"
-        logger.info(f"BANK_CALL_BASE_URL = {SimbrellaClient.BANK_CALL_BASE_URL}")
-        logger.info(f"Calling TransactionVerify endpoint with data: {data}")
+        # api_url = f"{SimbrellaClient.BANK_CALL_BASE_URL}/TransactionVerify"
+        # logger.info(f"BANK_CALL_BASE_URL = {SimbrellaClient.BANK_CALL_BASE_URL}")
+        # logger.info(f"Calling TransactionVerify endpoint with data: {data}")
 
         try:
-            logger.info(f"Here is your TransactionVerify Request data ***** : {data}")
-            response = requests.post(api_url, json=data, headers=get_headers())
-            logger.info(f"TransactionVerify response: {response.json()}")
+        #     logger.info(f"Here is your TransactionVerify Request data ***** : {data}")
+        #     response = requests.post(api_url, json=data, headers=get_headers())
+        #     logger.info(f"TransactionVerify response: {response.json()}")
 
-            return response.json()
+            return data
 
         except Exception as e:
             logger.info(f"Failed to call TransactionVerify endpoint: {e}")
@@ -103,9 +93,9 @@ class SimbrellaClient:
 
     @staticmethod
     def refresh_disbursement(data):
-        api_url = f"{SimbrellaClient.BANK_CALL_BASE_URL}/Disbursement"
-        logger.info(f"BANK_CALL_BASE_URL = {SimbrellaClient.BANK_CALL_BASE_URL}")
-        logger.info(f"Calling Disbursement endpoint with data: {data}")
+        # api_url = f"{SimbrellaClient.BANK_CALL_BASE_URL}/Disbursement"
+        # logger.info(f"BANK_CALL_BASE_URL = {SimbrellaClient.BANK_CALL_BASE_URL}")
+        # logger.info(f"Calling Disbursement endpoint with data: {data}")
 
         try:
             logger.info(f"Here is your Disbursement Request data ***** : {data}")
@@ -122,9 +112,9 @@ class SimbrellaClient:
 
     @staticmethod
     def payment_callback(data):
-        api_url = f"{SimbrellaClient.BANK_CALL_BASE_URL}/Payment"
-        logger.info(f"BANK_CALL_BASE_URL = {SimbrellaClient.BANK_CALL_BASE_URL}")
-        logger.info(f"Calling Payment Callback endpoint with data: {data}")
+        # api_url = f"{SimbrellaClient.BANK_CALL_BASE_URL}/Payment"
+        # logger.info(f"BANK_CALL_BASE_URL = {SimbrellaClient.BANK_CALL_BASE_URL}")
+        # logger.info(f"Calling Payment Callback endpoint with data: {data}")
 
         try:
             logger.info(f"Here is your Payment Callback Request data ***** : {data}")