- Ensure libraries are installed for each Python project (producter and consumer). See requirements.txt.
- Ensure Kafka is installed and started:
confluent local kafka start - Identify the Kafka port. Update
KAFKA_BOOTSTRAP_SERVERSin each main.py (producer and consumer) to that port. eg.KAFKA_BOOTSTRAP_SERVERS = ':56671' - Run
wikimedia_producer.py.
Folders and files
| Name | Name | Last commit date | ||
|---|---|---|---|---|