OptimizingPublicTransportation

Simulated and displayed the status of train lines from the Chicago Transit Authority dataset using a streaming event pipeline based on Apache Kafka. This primarily involved six steps which included the following: creating the Kafka producers, creating the Rest Proxy producer, configuring Kafka Connect for the connection between PostgreSQL database and Kafka, configuring the Faust Stream Processor, configuring the KSQL table, and finally creating the Kafka consumers. Python was the primary language used.