This is an automated email from the ASF dual-hosted git repository.

acosentino pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-performance-tests.git

commit 90c983ef081305bc6a3c1f9d0ad727e1b8b3f0c8
Author: Andrea Cosentino <[email protected]>
AuthorDate: Thu Sep 16 12:29:08 2021 +0200

    Kafka-Minio Burst script: Introduce Broker var
---
 profiling/kafka-minio/script/burst.sh | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)

diff --git a/profiling/kafka-minio/script/burst.sh 
b/profiling/kafka-minio/script/burst.sh
index ba3af3e..5adaaa4 100755
--- a/profiling/kafka-minio/script/burst.sh
+++ b/profiling/kafka-minio/script/burst.sh
@@ -20,6 +20,11 @@ while [[ $# -gt 0 ]]; do
       shift # past argument
       shift # past value
       ;;
+    -b|--broker)
+      BROKER="$2"
+      shift # past argument
+      shift # past value
+      ;;
     --default)
       DEFAULT=YES
       shift # past argument
@@ -35,5 +40,5 @@ set -- "${POSITIONAL[@]}" # restore positional parameters
 
 for i in $(seq 1 $NUMBER)
 do
-   echo $PAYLOAD | $KAFKACAT_PATH -b localhost:9092 -t $TOPIC -H "file=$(cat 
/dev/urandom | tr -dc '[:alpha:]' | fold -w ${1:-20} | head -n 1)"
+   echo $PAYLOAD | $KAFKACAT_PATH -b $BROKER -t $TOPIC -H "file=$(cat 
/dev/urandom | tr -dc '[:alpha:]' | fold -w ${1:-20} | head -n 1)"
 done

Reply via email to