blob: eea99ca27af6318e0b2fe3d370af48c16151fae0 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
|
#!/bin/bash -ue
# shellcheck disable=SC1091
. /scripts/common.sh
wait_topic fb-sink
for i in $(seq 1 100); do
sleep 1
echo "{ \"name\": \"object-$i\" }" | \
kafka-console-producer --topic fb-source \
--broker-list "$KAFKA_HOST:$KAFKA_PORT"
done
|