manifold-kafka:clj-kafka 的流形生产者和消费者

时间:2024-08-09 09:51:08
【文件属性】:

文件名称:manifold-kafka:clj-kafka 的流形生产者和消费者

文件大小:12KB

文件格式:ZIP

更新时间:2024-08-09 09:51:08

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)

网友评论