This page is not created by, affiliated with, or supported by Slack Technologies, Inc.
2021-07-26
Channels
- # aws-lambda (15)
- # babashka (7)
- # beginners (124)
- # calva (7)
- # cider (19)
- # clj-kondo (26)
- # clojure (261)
- # clojure-australia (3)
- # clojure-dev (10)
- # clojure-europe (45)
- # clojure-nl (4)
- # clojure-uk (6)
- # clojurescript (10)
- # datomic (7)
- # depstar (7)
- # emacs (11)
- # fulcro (41)
- # graalvm (48)
- # helix (1)
- # honeysql (17)
- # inf-clojure (7)
- # introduce-yourself (3)
- # jackdaw (2)
- # lsp (36)
- # malli (2)
- # meander (2)
- # membrane (1)
- # missionary (11)
- # off-topic (17)
- # pathom (83)
- # polylith (15)
- # re-frame (31)
- # reagent (42)
- # sci (35)
- # shadow-cljs (13)
- # spacemacs (13)
- # sql (19)
- # timbre (3)
- # tools-deps (77)
Hi! I am trying to use edn-serde
with Java interop. This is how my Properties
object looks like :
(defn config []
(doto (Properties.)
(.put StreamsConfig/APPLICATION_ID_CONFIG (env :application-id "xxx"))
(.put StreamsConfig/BOOTSTRAP_SERVERS_CONFIG (env :bootstrap-servers "localhost:9092"))
(.put StreamsConfig/STATE_DIR_CONFIG (env :state-dir "/tmp/kafka-streams"))
(.put StreamsConfig/DEFAULT_KEY_SERDE_CLASS_CONFIG "jackdaw.serdes.EdnSerde")
(.put StreamsConfig/DEFAULT_VALUE_SERDE_CLASS_CONFIG "jackdaw.serdes.EdnSerde")))
The above does not seem to work. Can anyone guide me on how I can use this?