A real-time data streaming pipeline built using Apache Kafka and Python. The project simulates continuous event generation by producing JSON messages and sending them to a Kafka topic in real time.
The pipeline demonstrates event-driven architecture concepts used in modern data engineering systems. It focuses on streaming data generation, message serialization, and real-time data flow between producer and Kafka broker.
This project highlights how data engineers design scalable streaming systems that handle continuous data ingestion and processing.