jocko:在Golang中实现的Kafka具有内置的协调功能(无需ZK dep单个二进制安装Cloud Native) 源码

黑猩猩 Go中的Kafka /分布式提交日志服务。 该项目的目标: 在Go中实施Kafka 协议与Kafka兼容,因此Kafka客户端和服务可与Jocko一起使用 使操作更简单 分发一个二进制文件 使用Serf进行发现,使用Raft进行共识(并消除了运行ZooKeeper的需要) 更智能的配置设置 能够将磁盘空间的百分比用于保留策略,而不是仅保留字节和保留时间 更改分区数或添加主题时处理大小配置 学到很多,玩得开心 去做 生产中 正在取得 分区共识和分配 协议 生产 取 元数据 创建主题 删除主题 消费者群体[当前任务] 发现 API版本控制[要实现的更多API