edn to gregor (kafka) conf

edn-to-gregor.clj

(require '[clojure.string :as s]
         '[gregor.core :as gregor])

(defn to-prop [k]
  (-> k name (s/replace #"-" ".")))

(defn to-props
  "ranames keys by converting them to strings and substituting dashes with periods
   only does top level keys"
  [conf]
  (into {}
    (for [[k v] conf]
      [(to-prop k) v])))

(defn edn-to-gregor [{:keys [bootstrap-servers group-id topics] :as conf}]
  [bootstrap-servers 
   group-id 
   topics 
   (to-props (dissoc conf :topics))])


;; --------------------------------------------

(def conf {:bootstrap-servers  "localhost:9092"
           :group-id           "testgroup"
           :auto-offset-reset  "earliest"
           :enable-auto-commit "false"
           :key-deserializer   "org.apache.kafka.common.serialization.ByteArrayDeserializer"
           :value-deserializer "org.apache.kafka.common.serialization.ByteArrayDeserializer"
           :topics             ["my-topic"]})

(apply gregor/consumer (edn-to-gregor conf))

;; => #object[org.apache.kafka.clients.consumer.KafkaConsumer 0x2fb84b38 "org.apache.kafka.clients.consumer.KafkaConsumer@2fb84b38"]