rsyslog/tests/sndrcv_kafka.sh
Andre Lorbach f5438bdea2 imkafka: Initial version if imkafka added
Basic features need to be added now.

testbench: Added kafka test with multi kafka instances

All kafka instances are connected to one zookeeper instance.
Diag script has been adjusted to propper start/stop single
kafka instances.

autotools: Added version check for librdkafka to be higher than 0.9.1
2017-05-09 11:15:20 +02:00

19 lines
679 B
Bash
Executable File

#!/bin/bash
# added 2017-05-03 by alorbach
# This file is part of the rsyslog project, released under ASL 2.0
echo ===============================================================================
echo \[sndrcv_kafka.sh\]: Create kafka/zookeeper instance and static topic
. $srcdir/diag.sh download-kafka
. $srcdir/diag.sh start-zookeeper
. $srcdir/diag.sh start-kafka
. $srcdir/diag.sh create-kafka-topic 'static'
echo \[sndrcv_kafka.sh\]: testing sending and receiving via kafka
. $srcdir/sndrcv_drvr.sh sndrcv_kafka 1000
echo \[sndrcv_kafka.sh\]: stop kafka instance
. $srcdir/diag.sh delete-kafka-topic 'static'
. $srcdir/diag.sh stop-kafka
. $srcdir/diag.sh stop-zookeeper