jackdaw

Sagar Vrajalal 2021-07-26T12:22:13.031900Z

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?

lepistane 2024-07-26T08:29:31.600099Z

did you manage to resolve it ?