blob: a7adbddf1ce03e949ca90330e909649df4f56252 (
plain)
1
2
3
4
5
6
7
8
9
|
#!/bin/bash -ue
# shellcheck disable=SC1091
. /scripts/common.sh
wait_kafka
kafka-topics --create --partitions 1 --replication-factor 1 --topic fb-source --bootstrap-server "$KAFKA_HOST:$KAFKA_PORT"
kafka-topics --create --partitions 1 --replication-factor 1 --topic fb-sink --bootstrap-server "$KAFKA_HOST:$KAFKA_PORT"
|
