From 45f1addf94e5a933728021f3051894f4d95b2467 Mon Sep 17 00:00:00 2001
From: Waleed Akbar <wakbar@cttc.es>
Date: Tue, 30 Jul 2024 14:49:57 +0000
Subject: [PATCH] dynamically creates the kafka server address with env
variables.
- get the values of KAFKA_NAMESPACE and KFK_SERVER_PORT to create KAFKA server address.
---
src/common/tools/kafka/Variables.py | 8 ++++++--
1 file changed, 6 insertions(+), 2 deletions(-)
diff --git a/src/common/tools/kafka/Variables.py b/src/common/tools/kafka/Variables.py
index 24ae2cff7..89ac42f90 100644
--- a/src/common/tools/kafka/Variables.py
+++ b/src/common/tools/kafka/Variables.py
@@ -16,14 +16,18 @@ import logging
from enum import Enum
from confluent_kafka import KafkaException
from confluent_kafka.admin import AdminClient, NewTopic
+from common.Settings import get_setting
LOGGER = logging.getLogger(__name__)
+KFK_SERVER_ADDRESS_TEMPLATE = 'kafka-service.{:s}.svc.cluster.local:{:s}'
class KafkaConfig(Enum):
+ KFK_NAMESPACE = get_setting('KFK_NAMESPACE')
+ KFK_PORT = get_setting('KFK_SERVER_PORT')
# SERVER_IP = "127.0.0.1:9092"
- SERVER_IP = "kafka-service.kafka.svc.cluster.local:9092"
- ADMIN_CLIENT = AdminClient({'bootstrap.servers': SERVER_IP})
+ server_address = KFK_SERVER_ADDRESS_TEMPLATE.format(KFK_NAMESPACE, KFK_PORT)
+ ADMIN_CLIENT = AdminClient({'bootstrap.servers': server_address})
class KafkaTopic(Enum):
REQUEST = 'topic_request'
--
GitLab