文件名称：port-kafka:Apache Kafka 的异步 Clojure 库
文件大小：11KB
文件格式：ZIP
更新时间：2024-07-26 15:19:39
Clojure
卡夫卡港 Apache Kafka 的异步 Clojure 库 使用通道、发布/和线程来处理您想要从 Kafka 消费的主题的消息。 使用编码/解码消息值。 用法 在大多数情况下，消费者、生产者和消息命名空间是围绕 Kafka java api 的瘦包装器。 消耗 ( ns some.ns ( :require [port-kafka.consumer :as c] [port-kafka.core :as pk])) ( defn consume-all-the-streams [...] ( let [consumer ( c/create consumer-config) consumer-streams ( c/create-topic-streams consumer { " my-topic " ( int 1 )
【文件预览】：
port-kafka-master
----.gitignore(84B)
----src()
--------port_kafka()
----LICENSE(11KB)
----doc()
--------intro.md(108B)
----README.md(2KB)
----demo()
--------demo.clj(2KB)
----project.clj(696B)