Setup your free Apache Kafka instance here: https://www.cloudkarafka.com
Configuration
export CLOUDKARAFKA_BROKERS="host1:9094,host2:9094,host3:9094"
Hostnames can be found in the Details view in for your CloudKarafka instance.export CLOUDKARAFKA_USERNAME="username"
Username can be found in the Details view in for your CloudKarafka instance.export CLOUDKARAFKA_PASSWORD="password"
Password can be found in the Details view in for your CloudKarafka instance.export CLOUDKARAFKA_TOPIC="username-topic"
Topic should be the same as your username followed by a dash before the topic.
These export commands must be run in both of the terminal windows below.
git clone https://github.com/CloudKarafka/python-kafka-example.git
cd python-kafka-example`
pip install confluent_kafka
python consumer.py
Open another terminal window and cd
into same directory and run python producer.py
.
Send your messages by pressing your system's EOF key sequence. (ctrl-d in bash)