From 864066802373c7c1d11b0e671be745180fe2478e Mon Sep 17 00:00:00 2001 From: Martino Date: Fri, 1 Mar 2019 15:15:36 +0000 Subject: [PATCH] use polling-interval-ms as passed in .. keep default at 100 since it was the one being used --- examples/dev/user.clj | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/examples/dev/user.clj b/examples/dev/user.clj index 3d1072b2..6a8cf120 100644 --- a/examples/dev/user.clj +++ b/examples/dev/user.clj @@ -106,14 +106,14 @@ "Takes a topic config, consumes from a Kafka topic, and returns a seq of maps." ([topic-config] - (get-records topic-config 200)) + (get-records topic-config 100)) ([topic-config polling-interval-ms] (let [client-config (kafka-consumer-config (str (java.util.UUID/randomUUID)))] (with-open [client (jc/subscribed-consumer client-config [topic-config])] - (doall (jcl/log client 100 seq)))))) + (doall (jcl/log client polling-interval-ms seq)))))) (defn get-keyvals