fluent-bit/examples/kafka_filter/scripts/kafka-consume.sh


1
2
3
4
5
6
7
8
9

#!/bin/bash -ue

# shellcheck disable=SC1091
. /scripts/common.sh

wait_topic fb-sink

kafka-console-consumer --topic fb-sink --bootstrap-server \
	"$KAFKA_HOST:$KAFKA_PORT"