文件名称：ketu:具有core.async集成的Clojure Kafka客户端
文件大小：36KB
文件格式：ZIP
更新时间：2024-05-12 13:40:08
Clojure
克图 具有core.async API的Clojure Apache Kafka客户端 [com.appsflyer/ketu " 0.6.0 " ] 特征 通道API ：从通道获取kafka数据，然后通过通道将数据发送到kafka。 消费者来源：从kafka轮询记录，并将其放在频道上。 生产者接收器：从通道中获取记录，并将其发送到kafka。 Shapes ：将Java客户端的原始对象转换为Clojure数据并返回。 配置简单：友好，经过验证的配置。 最小的例子 消费来自kafka的名称字符串，并通过所有渠道为该名称产生一个问候字符串，将其返回到kafka中： ( ns example ( :require [clojure.core.async :refer [chan close! <!! >!!]] [ketu.async.source :a
【文件预览】：
ketu-master
----.github()
--------workflows()
----src()
--------ketu()
----LICENSE(12KB)
----dev-resources()
--------dev-logback.xml(849B)
--------test-logback.xml(82B)
----test()
--------ketu()
----README.md(5KB)
----project.clj(2KB)
----.gitignore(142B)