From b485aab7e71c1625cfc27e0f92c9509f42378458 Mon Sep 17 00:00:00 2001
From: Daniel Baumann <daniel.baumann@progress-linux.org>
Date: Sun, 5 May 2024 13:19:16 +0200
Subject: Adding upstream version 1.45.3+dfsg.

Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>
---
 .../librdkafka-2.1.0/tests/delete-test-topics.sh   | 56 ++++++++++++++++++++++
 1 file changed, 56 insertions(+)
 create mode 100755 src/fluent-bit/lib/librdkafka-2.1.0/tests/delete-test-topics.sh

(limited to 'src/fluent-bit/lib/librdkafka-2.1.0/tests/delete-test-topics.sh')

diff --git a/src/fluent-bit/lib/librdkafka-2.1.0/tests/delete-test-topics.sh b/src/fluent-bit/lib/librdkafka-2.1.0/tests/delete-test-topics.sh
new file mode 100755
index 000000000..bc40bf65d
--- /dev/null
+++ b/src/fluent-bit/lib/librdkafka-2.1.0/tests/delete-test-topics.sh
@@ -0,0 +1,56 @@
+#!/bin/bash
+#
+
+set -e
+
+if [[ "$1" == "-n" ]]; then
+    DO_DELETE=0
+    shift
+else
+    DO_DELETE=1
+fi
+
+ZK=$1
+KATOPS=$2
+RE=$3
+
+if [[ -z "$ZK" ]]; then
+    ZK="$ZK_ADDRESS"
+fi
+
+if [[ -z "$KATOPS" ]]; then
+    if [[ -d "$KAFKA_PATH" ]]; then
+        KATOPS="$KAFKA_PATH/bin/kafka-topics.sh"
+    fi
+fi
+
+if [[ -z "$RE" ]]; then
+    RE="^rdkafkatest_"
+fi
+
+if [[ -z "$KATOPS" ]]; then
+    echo "Usage: $0 [-n] <zookeeper-address> <kafka-topics.sh> [<topic-name-regex>]"
+    echo ""
+    echo "Deletes all topics matching regex $RE"
+    echo ""
+    echo "  -n  - Just collect, dont actually delete anything"
+    exit 1
+fi
+
+set -u
+echo -n "Collecting list of matching topics... "
+TOPICS=$($KATOPS --zookeeper $ZK --list 2>/dev/null | grep "$RE") || true
+N_TOPICS=$(echo "$TOPICS" | wc -w)
+echo "$N_TOPICS topics found"
+
+
+for t in $TOPICS; do
+    if [[ $DO_DELETE == 1 ]]; then
+	echo -n "Deleting topic $t... "
+	($KATOPS --zookeeper $ZK --delete --topic "$t" 2>/dev/null && echo "deleted") || echo "failed"
+    else
+	echo "Topic $t"
+    fi
+done
+
+echo "Done"
-- 
cgit v1.2.3