Navigation Menu

Skip to content

Instantly share code, notes, and snippets.

@mccraigmccraig

mccraigmccraig/serde.clj

Created October 25, 2018 21:55
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 1 You must be signed in to fork a gist
  • Save mccraigmccraig/6fbd57cc29889079d511c2a42251f144 to your computer and use it in GitHub Desktop.
Save mccraigmccraig/6fbd57cc29889079d511c2a42251f144 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
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)))
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment