shovel:一个简单的 Clojure 库，用于使用 core.async 处理 Kafka 流

铲 一个简单的 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