文件名称:scoop:从Clojure REPL说起Kafka的协议
文件大小:11KB
文件格式:ZIP
更新时间:2024-05-28 19:09:58
clojure kafka Clojure
舀 /skuːp/非正式 报纸在竞争对手之前先发布的新闻,或者在电视或广播电台播放的新闻。 该项目的最初目标是直接与Apache Kafka对话,而无需任何中间人(例如,客户端/管理员API),并利用Clojure REPL作为对话界面。 从等式中删除API意味着我们可以说出Kafka的母语(Kafka协议)而无需API审查我们(例如验证我们发送的内容或限制我们获得的信息)。 简而言之,接受REPL对Kafka的采访。 这个想法的演变是使用clojure.spec来描述Kafka的协议请求,并将其与clojure.test.check的一些生成器结合起来,以查看Kafka如何在协议级别处理格式错误的输入。 通过添加一些崩溃意识,此工具可以轻松成为Kafka协议模糊器。 用法 只需启动REPL并使用BOOTSTRAP_SERVERS环境var指向Kafka集群即可。 BOOTSTRAP
【文件预览】:
scoop-master
----project.clj(384B)
----test()
--------scoop()
----src()
--------scoop()
----docker-compose.yml(1KB)
----.gitignore(99B)
----README.md(2KB)