1 files changed, 17 insertions, 0 deletions
diff --git a/fluent-bit/examples/kafka_filter/scripts/common.sh b/fluent-bit/examples/kafka_filter/scripts/common.sh
new file mode 100644
index 000000000..d9a2bc6f4
--- /dev/null
+++ b/fluent-bit/examples/kafka_filter/scripts/common.sh
@@ -0,0 +1,17 @@
+#!/bin/bash -ue
+
+wait_kafka() {
+	while ! nc -z "$KAFKA_HOST" "$KAFKA_PORT"; do
+		sleep 0.1
+	done
+}
+
+wait_topic() {
+	wait_kafka
+	local topic=$1
+	[ -z "$topic" ] && return 1
+	while true; do
+		kafka-topics --list --bootstrap-server "$KAFKA_HOST:$KAFKA_PORT" | grep -q "^$topic$" && break
+		sleep 0.1
+	done
+}