From 62031ac8df70d1540008d93ead429de8467155c9 Mon Sep 17 00:00:00 2001
From: Waleed Akbar <wakbar@cttc.es>
Date: Thu, 1 Aug 2024 12:53:52 +0000
Subject: [PATCH] changes to manage Kafka enviornment variable efficiently
- KFK_SERVER_PORT and KFK_REDOPLY added into my_deploy.sh file.
- refines kafka env variables import
---
my_deploy.sh | 5 +++++
src/common/tools/kafka/Variables.py | 8 ++++----
2 files changed, 9 insertions(+), 4 deletions(-)
diff --git a/my_deploy.sh b/my_deploy.sh
index b89df7481..45e0d1301 100755
--- a/my_deploy.sh
+++ b/my_deploy.sh
@@ -181,3 +181,8 @@ export GRAF_EXT_PORT_HTTP="3000"
# Set the namespace where Apache Kafka will be deployed.
export KFK_NAMESPACE="kafka"
+# Set the port Apache Kafka server will be exposed to.
+export KFK_SERVER_PORT="9092"
+
+# Set the flag to YES for redeploying of Apache Kafka
+export KFK_REDEPLOY=""
diff --git a/src/common/tools/kafka/Variables.py b/src/common/tools/kafka/Variables.py
index 9abc32b3e..e3ee2016a 100644
--- a/src/common/tools/kafka/Variables.py
+++ b/src/common/tools/kafka/Variables.py
@@ -23,11 +23,11 @@ LOGGER = logging.getLogger(__name__)
class KafkaConfig(Enum):
KFK_SERVER_ADDRESS_TEMPLATE = 'kafka-service.{:s}.svc.cluster.local:{:s}'
- KFK_NAMESPACE = get_setting('KFK_NAMESPACE')
- KFK_PORT = get_setting('KFK_SERVER_PORT')
- # SERVER_ADDRESS = "127.0.0.1:9092"
+ KFK_NAMESPACE = get_setting('KFK_NAMESPACE')
+ KFK_PORT = get_setting('KFK_SERVER_PORT')
+ # SERVER_ADDRESS = "127.0.0.1:9092"
SERVER_ADDRESS = KFK_SERVER_ADDRESS_TEMPLATE.format(KFK_NAMESPACE, KFK_PORT)
- ADMIN_CLIENT = AdminClient({'bootstrap.servers': SERVER_ADDRESS })
+ ADMIN_CLIENT = AdminClient({'bootstrap.servers': SERVER_ADDRESS })
class KafkaTopic(Enum):
REQUEST = 'topic_request'
--
GitLab