🚌 Kafka Bus Stop Alert System

Solving the School Pickup Coordination Challenge with Apache Kafka

3:10 PM

Meeting runs over

3:11 PM

Alert sent

3:12 PM

Neighbors notified

3:15 PM

Bus arrives

👩

Sarah

In Meeting

Producer.py
Sends alert to Kafka

Apache Kafka

📁 Topic: bus-stop-alerts

📧 Sarah: Meeting running late

✅ Persistent Storage

✅ Message Ordering

✅ Consumer Groups

✅ Fault Tolerance

👨

Mike

Ready to help

👩

Lisa

Available

👨

David

Phone was off

Consumer.py
Receives alerts

🚌

Bus Stop
3:15 PM

produce()

poll()

🔌

Decoupled Systems

Producers and consumers work independently

💾

Message Persistence

Messages stored safely, survive crashes

📊

Scalable

Add more consumers for load balancing

🔄

Reliable Delivery

Messages delivered even if consumer was offline