blob: d9a2bc6f47140b8187ad2d3b356084d2acdecfaa (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
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
}
|