【文件属性】：
文件名称：clojure-kafka-examples：Kafka和Kafka Streams的Clojure示例（JAVA Interop）
文件大小：53KB
文件格式：ZIP
更新时间：2021-02-02 11:21:49
java clojure kafka functional-programming kafka-topic
关于
使用带有Clojure的Kafka和Kafka流的示例示例。 我想通过Clojure而不是Clojure包装器来学习真正的Kafka API，因此这里是使用原始API的示例，它很干净，意味着您无需等待Clojure包装器库来升级Kafka。
有关示例的指南，请参见。
先决条件
期望能够设置Zookeeper和Kafka Broker来运行示例。 或使用Confluent平台。 Kafka Stream示例都具有相关的测试，而不是运行Jar。 请检查各个模块自述文件以检查其运行方式。
单元测试
检出每个文件的单元测试，以查看其运行状况，而无需与Zookeeper和Kafka一起运行。
例子
使用Java互操作在Clojure中的Kafka生产者和消费者。
搜索主题并返回从开始到当前时间点与键匹配的记录。
Kafka Streaming示例以大写字符串表示。
Kafka Streaming测试示例。
Kafka流式连接具有两个流（左连接，内部连接，外部连接）
Kafka Streaming与KTABLE一起加入。
Avro Kafka反序列化和序列化。
KStream
【文件预览】：
clojure-kafka-examples-master
----kafka-producer-consumer-example()
--------src()
--------Dockerfile(189B)
--------LICENSE(11KB)
--------test()
--------README.md(4KB)
--------.hgignore(136B)
--------project.clj(1020B)
--------.gitignore(161B)
--------bin()
----kafka-streams-examples-java()
--------src()
--------pom.xml(3KB)
----kafka-streams-example()
--------src()
--------LICENSE(11KB)
--------test()
--------README.md(286B)
--------project.clj(1KB)
--------.gitignore(113B)
--------CHANGELOG.md(796B)
----.travis.yml(367B)
----README.md(3KB)
----docker-compose.yml(809B)
----.gitignore(211B)