Distributed SystemsIn progress
Kafka Event Pipeline
Multi-consumer event streaming system with schema registry and DLQ
An event streaming pipeline built on Kafka with multiple consumer groups, a schema registry for safe contract evolution, and a dead-letter queue for poison messages — instrumented for consumer lag monitoring.
What it demonstrates
- Consumer group offsets
- Schema evolution
- At-least-once delivery
- Consumer lag monitoring
Tech stack
GoKafkaProtobuf