jocko:Kafka通过内置协调在Golang中实现(无需ZooKeeper单个二进制安装Cloud Native) 源码

黑猩猩 Go中与Kafka有线兼容的分布式提交日志服务。 由创建,由继续。 目标: 协议与Kafka兼容,因此Kafka客户端和服务可与Jocko一起使用 分发一个二进制文件 使用Serf进行发现,使用Raft进行共识(并消除了运行ZooKeeper的需要) 更简单的配置设置 去做 地图功能缺失 广泛的协议符合性测试服 将所有依赖关系和代码更新为最新的Go(截至MAR2020) 读 项目布局 ├── broker broker subsystem ├── cmd commands │ └── jocko command to run a Jocko broker and manage topics ├── commitlog low-level commit log implementation ├── examples