KafkaConnectionTest
A small tool to check the Kafka connection, e.g. to see if scripts on a server an communicate via a Kafka broker.
Usage
Producer and consumer script can run on the same machine. Before running set the correct env content of the env vars in setup_env.sh.
Producer
$ source set_env.sh
$ python producer.pyConsumer
$ source set_env.sh
$ python consumer.py