Added tools

itadventurer · Jun 24, 2019 · cb67d6f · cb67d6f
1 parent 1835248
commit cb67d6f
Show file tree

Hide file tree

Showing 50 changed files with 210 additions and 1,043 deletions.
diff --git a/bin/connect-distributed.sh b/bin/connect-distributed.sh
diff --git a/bin/connect-standalone.sh b/bin/connect-standalone.sh
diff --git a/bin/kafka-acls b/bin/kafka-acls
@@ -0,0 +1,9 @@
+#!/bin/bash
+PARAMS="$@"
+DIR=$( dirname "${BASH_SOURCE[0]}" )
+source "$DIR/utils.sh"
+
+PARAMS=$(add_bootstrap_servers "$PARAMS" "--bootstrap-server")
+PARAMS=$(add_tls "$PARAMS" "--command-config")
+
+exec $KAFKA_CLI_DIR/$(basename $0).sh $PARAMS
diff --git a/bin/kafka-acls.sh b/bin/kafka-acls.sh
diff --git a/bin/kafka-broker-api-versions b/bin/kafka-broker-api-versions
@@ -0,0 +1,9 @@
+#!/bin/bash
+PARAMS="$@"
+DIR=$( dirname "${BASH_SOURCE[0]}" )
+source "$DIR/utils.sh"
+
+PARAMS=$(add_bootstrap_servers "$PARAMS" "--bootstrap-server")
+PARAMS=$(add_tls "$PARAMS" "--command-config")
+
+exec $KAFKA_CLI_DIR/$(basename $0).sh $PARAMS
diff --git a/bin/kafka-broker-api-versions.sh b/bin/kafka-broker-api-versions.sh
diff --git a/bin/kafka-configs b/bin/kafka-configs
@@ -0,0 +1,8 @@
+#!/bin/bash
+PARAMS="$@"
+DIR=$( dirname "${BASH_SOURCE[0]}" )
+source "$DIR/utils.sh"
+
+PARAMS=$(add_zookeeper "$PARAMS" "--zookeeper")
+
+exec $KAFKA_CLI_DIR/$(basename $0).sh $PARAMS
diff --git a/bin/kafka-configs.sh b/bin/kafka-configs.sh
diff --git a/bin/kafka-console-consumer b/bin/kafka-console-consumer
@@ -0,0 +1,9 @@
+#!/bin/bash
+PARAMS="$@"
+DIR=$( dirname "${BASH_SOURCE[0]}" )
+source "$DIR/utils.sh"
+
+PARAMS=$(add_bootstrap_servers "$PARAMS" "--bootstrap-server")
+PARAMS=$(add_tls "$PARAMS" "--consumer.config")
+
+exec $KAFKA_CLI_DIR/$(basename $0).sh $PARAMS
diff --git a/bin/kafka-console-consumer.sh b/bin/kafka-console-consumer.sh
diff --git a/bin/kafka-console-producer b/bin/kafka-console-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
diff --git a/bin/kafka-console-producer.sh b/bin/kafka-console-producer.sh
diff --git a/bin/kafka-consumer-groups b/bin/kafka-consumer-groups
@@ -0,0 +1,9 @@
+#!/bin/bash
+PARAMS="$@"
+DIR=$( dirname "${BASH_SOURCE[0]}" )
+source "$DIR/utils.sh"
+
+PARAMS=$(add_bootstrap_servers "$PARAMS" "--bootstrap-server")
+PARAMS=$(add_tls "$PARAMS" "--command-config")
+
+exec $KAFKA_CLI_DIR/$(basename $0).sh $PARAMS
diff --git a/bin/kafka-consumer-groups.sh b/bin/kafka-consumer-groups.sh
diff --git a/bin/kafka-consumer-perf-test b/bin/kafka-consumer-perf-test
@@ -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" "--consumer.config")
+
+exec $KAFKA_CLI_DIR/$(basename $0).sh $PARAMS
diff --git a/bin/kafka-consumer-perf-test.sh b/bin/kafka-consumer-perf-test.sh
diff --git a/bin/kafka-delegation-tokens b/bin/kafka-delegation-tokens
@@ -0,0 +1,9 @@
+#!/bin/bash
+PARAMS="$@"
+DIR=$( dirname "${BASH_SOURCE[0]}" )
+source "$DIR/utils.sh"
+
+PARAMS=$(add_bootstrap_servers "$PARAMS" "--bootstrap-server")
+PARAMS=$(add_tls "$PARAMS" "--command-config")
+
+exec $KAFKA_CLI_DIR/$(basename $0).sh $PARAMS
diff --git a/bin/kafka-delegation-tokens.sh b/bin/kafka-delegation-tokens.sh
diff --git a/bin/kafka-delete-records b/bin/kafka-delete-records
@@ -0,0 +1,9 @@
+#!/bin/bash
+PARAMS="$@"
+DIR=$( dirname "${BASH_SOURCE[0]}" )
+source "$DIR/utils.sh"
+
+PARAMS=$(add_bootstrap_servers "$PARAMS" "--bootstrap-server")
+PARAMS=$(add_tls "$PARAMS" "--command-config")
+
+exec $KAFKA_CLI_DIR/$(basename $0).sh $PARAMS
diff --git a/bin/kafka-delete-records.sh b/bin/kafka-delete-records.sh
diff --git a/bin/kafka-dump-log.sh b/bin/kafka-dump-log.sh
diff --git a/bin/kafka-log-dirs b/bin/kafka-log-dirs
@@ -0,0 +1,9 @@
+#!/bin/bash
+PARAMS="$@"
+DIR=$( dirname "${BASH_SOURCE[0]}" )
+source "$DIR/utils.sh"
+
+PARAMS=$(add_bootstrap_servers "$PARAMS" "--bootstrap-server")
+PARAMS=$(add_tls "$PARAMS" "--command-config")
+
+exec $KAFKA_CLI_DIR/$(basename $0).sh $PARAMS