21 lines
512 B
Bash
Executable File
21 lines
512 B
Bash
Executable File
#!/bin/bash
|
|
|
|
display_usage() {
|
|
echo "Usage: $0 <KAFKA_BROKER> <KAFKA_TOPIC>"
|
|
}
|
|
|
|
if [ "$#" -ne 2 ]; then
|
|
display_usage
|
|
exit 1
|
|
fi
|
|
|
|
KAFKA_BROKER=$1
|
|
KAFKA_TOPIC=$2
|
|
|
|
STRINGS=("This is an example string" "The quick brown fox jumps over the lazy dog" "The unique example of word count")
|
|
|
|
while sleep 1; do
|
|
str=${STRINGS[$RANDOM % ${#STRINGS[@]}]}
|
|
epochSeconds=$(date '+%s')
|
|
echo "{\"ts\":$epochSeconds,\"str\":\"$str\"}" | kafka-console-producer.sh --broker-list ${KAFKA_BROKER} --topic ${KAFKA_TOPIC}
|
|
done |