halcyon-r/mini-kafka-go

golang编写的简易消息引擎，参考自kafka

Mini-kafka-go

golang实现的简易分布式消息引擎，参考Kafka和NSQ。

Overview

• 使用Etcd作为分布式协调服务和元数据存储
• 支持分区级别生产消费

Quick start