worked oon disbursement endpoint and added more things to log

app/integrations/kafka.py

@@ -53,6 +53,10 @@ class KafkaIntegration:
         consumer = KafkaIntegration._get_consumer()
         consumer.subscribe([topic])
 
+        logger.info(
+            f"Waiting for messages from topic {topic} with this timeout: {timeout}..."
+        )
+
         try:
             msg = consumer.poll(timeout=timeout)
             if msg is None:
@@ -89,6 +93,8 @@ class KafkaIntegration:
     @staticmethod
     def _call_disbursement_endpoint(message):
         """Call the disbursement endpoint with the received message"""
+        logger.info(f"Calling disbursement endpoint with message: {message}")
+
         try:
             response = disbursement_endpoint(message)
             logger.info(