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