From f4b9fa91d9de8ae3f89e89c2265686733cd8c00f Mon Sep 17 00:00:00 2001
From: Waleed Akbar <wakbar@cttc.es>
Date: Tue, 6 Aug 2024 14:57:33 +0000
Subject: [PATCH] updated Kafka deployment script.
-
---
deploy/kafka.sh | 8 +++++---
1 file changed, 5 insertions(+), 3 deletions(-)
diff --git a/deploy/kafka.sh b/deploy/kafka.sh
index 21ba89408..f86108011 100755
--- a/deploy/kafka.sh
+++ b/deploy/kafka.sh
@@ -78,11 +78,13 @@ function kafka_deploy() {
echo "Apache Kafka"
echo ">>> Checking if Apache Kafka is deployed ... "
-if [ "$KFK_REDEPLOY" == "YES" ]; then
+if [ "$KFK_REDEPLOY" = "YES" ]; then
+ echo ">>> Redeploying kafka namespace"
kafka_deploy
-elif kubectl get --namespace ${KFK_NAMESPACE} deployments.apps &> /dev/null; then
- echo ">>> Apache Kafka already present; skipping step."
+elif kubectl get namespace "${KFK_NAMESPACE}" &> /dev/null; then
+ echo ">>> Apache Kafka already present; skipping step."
else
+ echo ">>> Kafka namespace doesn't exists. Deploying kafka namespace"
kafka_deploy
fi
echo
--
GitLab