Fork me on GitHub
#jackdaw
<
2021-07-26
>
Sagar Vrajalal12:07:13

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?