Bugfixes: inconsistent parameters make me mad

bin/kafka-console-consumer

@@ -1 +1 @@
-run-cli-tool-with-kafka-bootstrap-server
+run-cli-tool-with-kafka-bootstrap-server-consumer

bin/kafka-console-producer

@@ -1 +1 @@
-run-cli-tool-with-kafka-broker-list
+run-cli-tool-with-kafka-broker-list-producer

bin/kafka-consumer-perf-test

@@ -1 +1 @@
-run-cli-tool-with-kafka-broker-list
+run-cli-tool-with-kafka-broker-list-consumer

bin/kafka-streams-application-reset

@@ -1,4 +1,4 @@
 #!/bin/bash
 BOOTSTRAP_SERVERS_PARAM="--bootstrap-servers"
-TLS_CONFIG_PARAM="--command-config"
+TLS_CONFIG_PARAM="--config-file"
 source $(dirname $0)/run-kafka-cli-tool.sh

bin/kafka-verifiable-consumer

@@ -1 +1 @@
-run-cli-tool-with-kafka-broker-list
+run-cli-tool-with-kafka-broker-list-consumer

bin/kafka-verifiable-producer

@@ -1 +1 @@
-run-cli-tool-with-kafka-broker-list
+run-cli-tool-with-kafka-broker-list-producer

bin/run-cli-tool-with-kafka-bootstrap-server-consumer

@@ -0,0 +1,4 @@
+#!/bin/bash
+BOOTSTRAP_SERVERS_PARAM="--bootstrap-server"
+TLS_CONFIG_PARAM="--consumer.config"
+source $(dirname $0)/run-kafka-cli-tool.sh

bin/run-cli-tool-with-kafka-broker-list → bin/run-cli-tool-with-kafka-broker-list-consumer

@@ -4,6 +4,6 @@ DIR=$( dirname "${BASH_SOURCE[0]}" )
 source "$DIR/utils.sh"
 
 PARAMS=$(add_bootstrap_servers "$PARAMS" "--broker-list")
-PARAMS=$(add_tls "$PARAMS" "--config-file")
+PARAMS=$(add_tls "$PARAMS" "--consumer.config")
 
 exec $KAFKA_CLI_DIR/$(basename $0).sh $PARAMS

bin/run-cli-tool-with-kafka-broker-list-producer

@@ -0,0 +1,9 @@
+#!/bin/bash
+PARAMS="$@"
+DIR=$( dirname "${BASH_SOURCE[0]}" )
+source "$DIR/utils.sh"
+
+PARAMS=$(add_bootstrap_servers "$PARAMS" "--broker-list")
+PARAMS=$(add_tls "$PARAMS" "--producer.config")
+
+exec $KAFKA_CLI_DIR/$(basename $0).sh $PARAMS

bin/test-toolbox.sh

@@ -9,7 +9,7 @@ function test_script {
 
     echo -e -n "\b"
 
-    if [ -z "$(cat /tmp/err)" ]  || [ "$(cat /tmp/err)" != "Processed a total of 2 messages\n" ] ; then
+    if [ -z "$(cat /tmp/err)" ]  || [ "$(cat /tmp/err)" == "Processed a total of 2 messages\n" ] ; then
         echo -e "${bold}${green}✓${normal}"
     else
         echo -e "${bold}${red}✗${normal}"

bin/utils.sh

@@ -120,7 +120,7 @@ function add_tls() {
         echo "ssl.truststore.location: $TRUSTSTORE_LOCATION" >> $CONFIG_FILE
         echo "ssl.truststore.password: $KEYSTORE_PASSWORD" >> $CONFIG_FILE
 
-        add_param_from_env $CONFIG_FILE "$PARAM" "$PARAMS"
+        PARAMS=$(add_param_from_env $CONFIG_FILE "$PARAM" "$PARAMS")
     fi
     echo "$PARAMS"
 }