A high-throughput event bus implementation in Go, capable of handling 1M+ events/sec with minimal latency. Used for inter-service communication in microservices architecture.
Project Overview
This project implements a distributed event bus using Go. It leverages Kafka for message durability and gRPC for high-performance communication between services. The system is designed to handle over 1 million events per second with sub-millisecond latency. Key features include automatic partition rebalancing, dead-letter queues, and comprehensive metrics via Prometheus.
Technology Stack
Go
Kafka
gRPC