文件名称：clojure-kafka-examples：Kafka和Kafka Streams的Clojure示例（JAVA Interop）
文件大小：53KB
文件格式：ZIP
更新时间：2024-02-23 05:08:29
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)