diff --git a/CHANGELOG.md b/CHANGELOG.md
index 711dbd14..e9dd5af9 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -2,6 +2,8 @@
 
 ## Unreleased
 
+* Allow map with keyword keys in streams constructor.
+
 ### Added
 
 ### Fixed
@@ -18,6 +20,7 @@
 
 * Fix `ktable` constructor to use supplied `store-name` 
 
+
 * Bump `clj-uuid` version to `0.1.9`
 
 * Minor update to fix harmless but distracting reflection warnings
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."