Updated installation and components

[nonrtric/plt/ranpm.git] / install / scripts / create_topic.sh

diff --git a/install/scripts/create_topic.sh b/install/scripts/create_topic.sh
index debc00f..77655ed 100644 (file)
--- a/install/scripts/create_topic.sh
+++ b/install/scripts/create_topic.sh
@@ -37,7 +37,7 @@ create_topic() {
 
     echo "Creating topic: $topic with $partitions partition(s) in $kafka"
 
-    kubectl exec -it client -n nonrtric -- bash -c 'kafka-topics --create --topic '$topic'  --partitions '$partitions' --bootstrap-server '$kafka
+    kubectl exec -it kafka-client -n nonrtric -- bash -c 'kafka-topics --create --topic '$topic'  --partitions '$partitions' --bootstrap-server '$kafka
 
     return $?
 }