Merge pull request #52 from OpenNyAI/container-id

Added container ID fetch script

scripts/create-topic.sh

@@ -2,8 +2,16 @@
 
 topic=$1
 
-docker exec -i jb-manager-kafka-1 kafka-topics.sh --create --bootstrap-server localhost:9092 --topic $topic
+# Get the container ID for the service
+CONTAINER_ID=$(./scripts/get-container-id.sh kafka)
 
+# Check for error
+if [ $? -ne 0 ]; then
+    exit 1
+fi
+
+# Create the topic
+docker exec -i $CONTAINER_ID kafka-topics.sh --create --bootstrap-server localhost:9092 --topic $topic
 
 
 

scripts/delete-topic.sh

@@ -2,7 +2,15 @@
 
 topic=$1
 
-docker exec -i jb-manager-kafka-1 kafka-topics.sh --delete --bootstrap-server localhost:9092 --topic $topic
+# Get the container ID for the service
+CONTAINER_ID=$(./scripts/get-container-id.sh kafka)
+
+# Check for error
+if [ $? -ne 0 ]; then
+    exit 1
+fi
+
+docker exec -i $CONTAINER_ID kafka-topics.sh --delete --bootstrap-server localhost:9092 --topic $topic
 
 
 

scripts/get-container-id.sh

@@ -0,0 +1,12 @@
+# Service name as defined in docker-compose.yml
+SERVICE_NAME=$1
+
+# Get the container ID for the service
+CONTAINER_ID=$(docker-compose ps -q $SERVICE_NAME)
+
+# Check if the container is running
+if [ -z "$CONTAINER_ID" ]; then
+    echo "No running container found for service: $SERVICE_NAME"
+    exit 1
+fi
+echo $CONTAINER_ID

scripts/read-message.sh

@@ -3,4 +3,12 @@
 topic=$1
 message=$2
 
-docker exec -i jb-manager-kafka-1 kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic $topic
+# Get the container ID for the service
+CONTAINER_ID=$(./scripts/get-container-id.sh kafka)
+
+# Check for error
+if [ $? -ne 0 ]; then
+    exit 1
+fi
+
+docker exec -i $CONTAINER_ID kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic $topic

scripts/send-message.sh

@@ -3,5 +3,13 @@
 topic=$1
 message=$2
 
-echo $message | docker exec -i jb-manager-kafka-1 kafka-console-producer.sh --bootstrap-server localhost:9092 --topic $topic
+# Get the container ID for the service
+CONTAINER_ID=$(./scripts/get-container-id.sh kafka)
+
+# Check for error
+if [ $? -ne 0 ]; then
+    exit 1
+fi
+
+echo $message | docker exec -i $CONTAINER_ID kafka-console-producer.sh --bootstrap-server localhost:9092 --topic $topic
 echo "Sent message to $topic"