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