The code from this repository generates grocery purchases that are sent to an Apache Kafka topic.
- Install dependencies:
pip install -r requirements.txt-
Configure your Apache Kafka cluster: rename config-example.py into config.py and set your Apache Kafka URI there. Also create a folder Certificates and add Apache Kafka certificates - ca.pem, service.cert and service.key into it.
-
Create a topic CDC-inputin the Apache Kafka service
-
Run the script:
python makeData.py