Distributed Event Bus.
A high-throughput, fault-tolerant event streaming platform built with Go and Kafka, ensuring 'at-least-once' delivery at scale.
Go
Kafka
Docker
gRPC
Overview
Designed to resolve the 'at-least-once' delivery guarantee challenge in distributed microservices. This system decouples critical services by providing a persistent, sharded message queue capable of withstanding network partitions and node failures without data loss.
Technical Challenge
Ensuring strict message ordering per-entity during high-concurrency rebalancing was the primary bottleneck. I implemented a consistent hashing strategy for partition assignment and custom consumer group logic in Go to guarantee processing order while maximizing parallel throughput.