From d429b76e1d2bdc3590d524d941b31ff1f0f10f39 Mon Sep 17 00:00:00 2001 From: lennyaiko Date: Thu, 10 Apr 2025 16:48:37 +0100 Subject: [PATCH] done with chore --- app/integrations/kafka.py | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/app/integrations/kafka.py b/app/integrations/kafka.py index 257c71f..385937a 100644 --- a/app/integrations/kafka.py +++ b/app/integrations/kafka.py @@ -6,6 +6,9 @@ import requests class KafkaIntegration: + + BASE_URL = settings.SIMBRELLA_BASE_URL + _consumer = None _consumer_config = { @@ -83,9 +86,7 @@ class KafkaIntegration: logger.info("Kafka consumer closed") @staticmethod - def _call_disbursement_endpoint( - message, endpoint_url="http://localhost:8000/loans/disbursement" - ): + def _call_disbursement_endpoint(message, endpoint_url=f"{BASE_URL}/Disbursement"): """Call an HTTP endpoint with the received message""" try: response = requests.post(endpoint_url, json=message, timeout=5) -- 2.34.1