serde.clj

(ns er-model.connectors.kafka.serde
  (:require
   [er-model.connectors.kafka.serializers :as k.ser]
   [er-model.connectors.kafka.deserializers :as k.deser])
  (:import
   [org.apache.kafka.common.serialization
    Serde
    Serdes
    Serdes$StringSerde
    Serdes$WrapperSerde]))

(defn string-serde
  []
  (Serdes$StringSerde.))

(defn edn-serde
  []
  (Serdes$WrapperSerde.
   (k.ser/edn-serializer)
   (k.deser/edn-deserializer)))