This project ingests a real-time data stream from Wikimedia into kafka server. The data is then written to a MySQL database.
- Wikimedia event stream
- Apache Kafka
- Java
- Maven build tools
- Spring Framework
- Spring Boot
- Spring JPA
- Docker
- MySQL
- Data Ingestion via Wikimedia url
- Publish data Kafka topic
- Configure Kafka consumer to write event data to local MySQL db
Ensure Kafka broker is running via docker compose.
docker-compose up
Run Java SpringBootProducerApp using Maven to write event data to Kafka topic.
Run Java SpringBootConsumerApp using Maven to pull data from Kafka and write to MySQL database.