From 43c7923197d48bdc6aad9b9bd009e5cfeac33336 Mon Sep 17 00:00:00 2001
From: Marc Wodahl <mwodahl@trihydro.com>
Date: Thu, 25 Jan 2024 09:20:51 -0700
Subject: [PATCH] Move KAFKA_CONTAINER_NAME to waitForKafkaToCreateTopics

---
 do_kafka_test.sh | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/do_kafka_test.sh b/do_kafka_test.sh
index 3ddef7f6..6d7c0637 100755
--- a/do_kafka_test.sh
+++ b/do_kafka_test.sh
@@ -13,7 +13,6 @@ YELLOW='\033[1;33m'
 NC='\033[0m' # No Color
 
 
-KAFKA_CONTAINER_NAME=$(docker ps --format '{{.Names}}' | grep kafka)
 MAP_FILE=data/I_80.edges
 BSM_DATA_FILE=data/I_80_test.json
 TIM_DATA_FILE=data/I_80_test_TIMS.json
@@ -36,7 +35,7 @@ setup() {
     # print setup info
     echo "=== Setup Info ==="
     echo "DOCKER_HOST_IP: $DOCKER_HOST_IP"
-    echo "KAFKA_CONTAINER_NAME: $KAFKA_CONTAINER_NAME"
+    echo "KAFKA_CONTAINER_NAME is resolved dynamically"
     echo "MAP_FILE: $MAP_FILE"
     echo "BSM_DATA_FILE: $BSM_DATA_FILE"
     echo "TIM_DATA_FILE: $TIM_DATA_FILE"
@@ -51,6 +50,7 @@ setup() {
 waitForKafkaToCreateTopics() {
     maxAttempts=100
     attempts=0
+    KAFKA_CONTAINER_NAME=$(docker ps --format '{{.Names}}' | grep kafka)
     while true; do
         attempts=$((attempts+1))
         if [ $(docker ps | grep $KAFKA_CONTAINER_NAME | wc -l) == "0" ]; then