From 6e222e73b11a30db2cc15dfa73783d766b843c27 Mon Sep 17 00:00:00 2001
From: Aleksander Madland Stapnes <madland.stapnes@gmail.com>
Date: Wed, 3 Jun 2020 12:04:07 -0300
Subject: [PATCH] Use jd/map->Properties on kafka-streams opts

---
 CHANGELOG.md            | 4 +++-
 src/jackdaw/streams.clj | 7 +++----
 2 files changed, 6 insertions(+), 5 deletions(-)

diff --git a/CHANGELOG.md b/CHANGELOG.md
index 7a58c2fa..860e4c77 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -2,7 +2,9 @@
 
 ## Unreleased
 
-* Fix `ktable` constructor to use supplied `store-name` 
+* Allow map with keyword keys in streams constructor.
+
+* Fix `ktable` constructor to use supplied `store-name`
 
 ## [0.7.3] - [2020-04-08]
 
diff --git a/src/jackdaw/streams.clj b/src/jackdaw/streams.clj
index 62170a10..df1aaef5 100644
--- a/src/jackdaw/streams.clj
+++ b/src/jackdaw/streams.clj
@@ -3,6 +3,7 @@
   {:license "BSD 3-Clause License <https://github.com/FundingCircle/jackdaw/blob/master/LICENSE>"}
   (:refer-clojure :exclude [count map merge reduce group-by filter peek])
   (:require [clojure.string :as str]
+            [jackdaw.data :as jd]
             [jackdaw.streams.interop :as interop]
             [jackdaw.streams.protocols :as p])
   (:import org.apache.kafka.streams.KafkaStreams
@@ -315,10 +316,8 @@
 (defn kafka-streams
   "Makes a Kafka Streams object."
   ([builder opts]
-   (let [props (java.util.Properties.)]
-     (.putAll props opts)
-     (KafkaStreams. ^Topology (.build ^StreamsBuilder (streams-builder* builder))
-                    ^java.util.Properties props))))
+   (KafkaStreams. ^Topology (.build (streams-builder* builder))
+                  (jd/map->Properties opts))))
 
 (defn start
   "Starts processing."