port kafka Apache Kafka的异步Clojure库

卡夫卡港Apache Kafka的异步Clojure库使用通道、发布/和线程来处理您想要从Kafka消费的主题的消息。使用编码/解码消息值。用法在大多数情况下，消费者、生产者和消息命名空间是围绕Kafka java api的瘦包装器。消耗( ns some.ns ( :require [port-kafka.consumer :as c] [port-kafka.core :as pk])) ( defn consume-all-the-streams [...] ( let [consumer ( c/create consumer-config) consumer-streams ( c/create-topic-streams consumer { " my-topic " ( int 1 )