clojure kafka examples:Kafka和Kafka Streams的Clojure示例(JAVA Interop) 源码

关于 使用带有Clojure的Kafka和Kafka流的示例示例。 我想通过Clojure而不是Clojure包装器来学习真正的Kafka API,因此这里是使用原始API的示例,它很干净,意味着您无需等待Clojure包装器库来升级Kafka。 有关示例的指南,请参见。 先决条件 期望能够设置Zookeeper和Kafka Broker来运行示例。 或使用Confluent平台。 Kafka Stream示例都具有相关的测试,而不是运行Jar。 请检查各个模块自述文件以检查其运行方式。 单元测试 检出每个文件的单元测试,以查看其运行状况,而无需与Zookeeper和Kafka一起运行。 例