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?did you manage to resolve it ?