DigiFi/digifi-EventManager
1
0
Fork 0
Code Issues Pull Requests 1 Releases Activity

done with chore

Browse Source
This commit was merged in pull request #4.
This commit is contained in:
lennyaiko
2025-04-10 16:48:37 +01:00
parent 26cf9307d2
commit d429b76e1d
1 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
app/integrations/kafka.py
+4 -3
View File
@@ -6,6 +6,9 @@ import requests
class KafkaIntegration: class KafkaIntegration:
BASE_URL = settings.SIMBRELLA_BASE_URL
_consumer = None _consumer = None
_consumer_config = { _consumer_config = {
@@ -83,9 +86,7 @@ class KafkaIntegration:
logger.info("Kafka consumer closed") logger.info("Kafka consumer closed")
@staticmethod @staticmethod
def _call_disbursement_endpoint( def _call_disbursement_endpoint(message, endpoint_url=f"{BASE_URL}/Disbursement"):
message, endpoint_url="http://localhost:8000/loans/disbursement"
):
"""Call an HTTP endpoint with the received message""" """Call an HTTP endpoint with the received message"""
try: try:
response = requests.post(endpoint_url, json=message, timeout=5) response = requests.post(endpoint_url, json=message, timeout=5)