【文件属性】：
文件名称：manifold-kafka:clj-kafka 的流形生产者和消费者
文件大小：12KB
文件格式：ZIP
更新时间：2021-07-20 16:04:28
Clojure
流形卡夫卡
生产者和消费者
当前构建状态：
流形kafka的想法是能够像使用简单的流形流一样使用kafka。
用法
制作人
( require '[manifold-kafka.producer :refer [producer]]
'[manifold.stream :refer [put! close!]])
( def config { " metadata.broker.list " " localhost:9999 "
" serializer.class " " kafka.serializer.DefaultEncoder "
" partitioner.class " " kafka.producer.DefaultPartitioner " })
( def p ( producer config
【文件预览】：
manifold-kafka-master
----.travis.yml(49B)
----project.clj(664B)
----test()
--------manifold_kafka()
----LICENSE(11KB)
----src()
--------manifold_kafka()
----.gitignore(152B)
----dev-resources()
--------log4j.properties(322B)
----README.md(1KB)