1. 首页
  2. 数据库
  3. 其它
  4. jocko:在Golang中实现的Kafka具有内置的协调功能(无需ZK dep单个二进制安装Cloud Native) 源码

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

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