文件名称：shovel:一个简单的 Clojure 库，用于使用 core.async 处理 Kafka 流
文件大小：101KB
文件格式：ZIP
更新时间：2024-07-08 04:59:16
Clojure
铲 一个简单的 Clojure 库，用于使用 core.async 处理 Kafka 流。 它有一个简单的（高级）消费者和一个简单的生产者。 适用于 Kafka 0.8.1 或更新版本。 版本和依赖信息 有两个版本： 用于旧 API 用于新 API (kafka-clients) 莱宁根依赖信息： [shovel " 0.2.2 " ] [shovel " 0.3.1 " ] 内件 与卡夫卡交谈 生产 这是第一次尝试远程安全和简单的东西，现实是您无法以这种方式捕获在发送期间生成的异常。 我需要研究如何使用 Kafka 可靠地传递消息并在发送失败时返回错误。 ( defn produce [^Producer producer ^KeyedMessage message] ( log/debug " fn: produce params: " producer messag
【文件预览】：
shovel-master
----conf()
--------app.edn(3KB)
----README.html(439KB)
----shovel.iml(3KB)
----src()
--------shovel()
----doc()
--------intro.md(124B)
----LICENSE(571B)
----test()
--------shovel()
----README.md(5KB)
----project.clj(1KB)
----resources()
--------docker()
--------scripts()
--------config()
--------log4j.properties(685B)
--------logback.xml(1KB)
----.gitignore(91B)