Kafka Producers in Python

example program to get data from firehose and send it to kafka

how to setup environment

1. create virtual environment

pyenv install 3.12.4

2. set the local python version

pyenv local 3.12.4

3. create virtual environment with venv

pyenv exec python -m venv kafka_env

4. activate the virtual environment

source kafka_env/bin/activate

5. install the required packages

kafka_env/bin/pip3 install -r requirements.txt

how to run

kafka_env/bin/python3 stream.py