Ignore nil values from kafka config

CloudKarafka · Mar 20, 2019 · 3d3b9c0 · 3d3b9c0
1 parent c299fc6
commit 3d3b9c0
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/src/cloudkarafka/kafkaadmin.clj b/src/cloudkarafka/kafkaadmin.clj
@@ -4,7 +4,9 @@
 (defn map->props
   [m]
   (let [props (java.util.Properties.)]
-    (doseq [[k v] m] (.put props (name k) v))
+    (doseq [[k v] m
+            :when (and k v)]
+      (.put props (name k) v))
     props))
 
 (defn member-list [group-name desc group-offset log-offset]