Distributed Systems
Kafka from Scratch
- Kafka broker built in Go — TCP server, wire-protocol framing, ApiVersions & Fetch APIs
- Concurrent connection handling with goroutines and length-prefixed binary parsing
Go
TCP
Concurrency
View on GitHub →