文件名称:gregor:Go 中的简约 Kafka 克隆
文件大小:8KB
文件格式:ZIP
更新时间:2024-06-25 03:20:10
Go
格雷戈尔 Gregor是用 Go 编写的简约 Kafka 克隆。 仅用于教育目的,尚未努力保持与 Kafka 协议的完全兼容性。 除了 Go 之外,有几个部分可能看起来是 Kafka 的密切音译。 这没关系,不要惊慌。 呼吸,然后移动到另一个部分。 存储层可用于操作 Kafka 日志段,因为它可以写入和读取与 Kafka 0.8.x 二进制兼容的日志段。 Kafka 的精简实现也可能有价值,它在单台机器上充当可索引的日志服务,用于测试/低资源环境。 如果没有多代理复制,这将是一个相当不可靠的系统,但在 DIY 环境中则不需要。 ###跑步 $ go build $ ./gregor 现在,Gregor 只是在 /tmp/ 中吐出一个日志段文件 ###路线图 用于操作 Kafka 日志段的 CLI 工具 看法 从磁盘或 S3 重播到集群 任何类似于安全文件 IO 的东西 日志索引 元
【文件预览】:
gregor-master
----main.go(491B)
----LICENSE(1KB)
----README.md(1KB)
----.gitignore(266B)
----storage()
--------messageset.go(3KB)
--------message_test.go(1KB)
--------message.go(4KB)
--------log.go(405B)
--------logsegment.go(1KB)
--------offsetindex.go(325B)
--------messageset_test.go(1KB)