Merge branch 'bank-simbrella-calls' into vivian-update-01

app/api/integrations/kafka.py

@@ -21,23 +21,26 @@ class KafkaIntegration:
         """Kafka producer"""
         if not KafkaIntegration._producer:
             KafkaIntegration._producer = Producer(KafkaIntegration._config)
+
             logger.info(
                 f"Connected to Kafka broker at {KafkaIntegration._config['bootstrap.servers']}"
             )
 
         return KafkaIntegration._producer
 
+
     @staticmethod
     def delivery_report(err, msg):
         """Called once for each message produced"""
         if err is not None:
-            logger.error(f"Message delivery failed: {err}")
-            raise RuntimeError(f"Message delivery failed: {err}")
 
+            logger.error(f'Message delivery failed: {err}')
+            raise RuntimeError(f"Message delivery failed: {err}")
+        
         else:
-            logger.debug(
-                f"Message delivered to {msg.topic()} [{msg.partition()}] @ offset {msg.offset()}"
-            )
+            logger.debug(f'Message delivered to {msg.topic()} [{msg.partition()}] @ offset {msg.offset()}')
+
+
 
     @staticmethod
     def send_loan_request(loan_data, request_id):
@@ -59,6 +62,7 @@ class KafkaIntegration:
                 key=str(request_id),
                 value=json.dumps(loan_data).encode("utf-8"),
                 callback=KafkaIntegration.delivery_report,
+
             )
 
             producer.poll(0)