JsonDeserializer error #2
Description
Hi Yossi,
We're trying out the Kafka subscription-consumer (from Franzy-examples) with a slight modification to include your JSON deserializer (Franzy JSON). The [ymilky/franzy-json "0.0.1"] is added in as a dependency, and so are other deps according to your specs. We're running a plain Clojure demo in lein env to get through a first pass without errors, but unfortunately, can't get past this error
kafka-consumer.zip
:
Exception in thread "main" org.apache.kafka.common.config.ConfigException: Invalid value franzy.serialization.json.deserializers.JsonDeserializer for configuration value.deserializer: Class franzy.serialization.json.deserializers.JsonDeserializer could not be found., compiling:(/private/var/folders/xw/bzhwyg451sx2cy76r7c9pbxw0000gn/T/form-init4247265754724557095.clj:1:125)
at clojure.lang.Compiler.load(Compiler.java:7391)
at clojure.lang.Compiler.loadFile(Compiler.java:7317)
at clojure.main$load_script.invokeStatic(main.clj:275)
at clojure.main$init_opt.invokeStatic(main.clj:277)
at clojure.main$init_opt.invoke(main.clj:277)
at clojure.main$initialize.invokeStatic(main.clj:308)
at clojure.main$null_opt.invokeStatic(main.clj:342)
at clojure.main$null_opt.invoke(main.clj:339)
at clojure.main$main.invokeStatic(main.clj:421)
at clojure.main$main.doInvoke(main.clj:384)
at clojure.lang.RestFn.invoke(RestFn.java:421)
at clojure.lang.Var.invoke(Var.java:383)
at clojure.lang.AFn.applyToHelper(AFn.java:156)
at clojure.lang.Var.applyTo(Var.java:700)
at clojure.main.main(main.java:37)
Caused by: org.apache.kafka.common.config.ConfigException: Invalid value franzy.serialization.json.deserializers.JsonDeserializer for configuration value.deserializer: Class franzy.serialization.json.deserializers.JsonDeserializer could not be found.
at org.apache.kafka.common.config.ConfigDef.parseType(ConfigDef.java:255)
at org.apache.kafka.common.config.ConfigDef.parse(ConfigDef.java:145)
at org.apache.kafka.common.config.AbstractConfig.(AbstractConfig.java:49)
at org.apache.kafka.common.config.AbstractConfig.(AbstractConfig.java:56)
at org.apache.kafka.clients.consumer.ConsumerConfig.(ConsumerConfig.java:336)
at org.apache.kafka.clients.consumer.KafkaConsumer.(KafkaConsumer.java:542)
at franzy.clients.consumer.client$eval3919$make_consumer__3936$fn__3943.invoke(client.clj:352)
at franzy.clients.consumer.client$eval3919$make_consumer__3936.invoke(client.clj:294)
at stream_processor.core$_main.invokeStatic(core.clj:31)
at stream_processor.core$_main.doInvoke(core.clj:12)
at clojure.lang.RestFn.invoke(RestFn.java:397)
at clojure.lang.Var.invoke(Var.java:375)
at user$eval5.invokeStatic(form-init4247265754724557095.clj:1)
at user$eval5.invoke(form-init4247265754724557095.clj:1)
at clojure.lang.Compiler.eval(Compiler.java:6927)
at clojure.lang.Compiler.eval(Compiler.java:6917)
at clojure.lang.Compiler.load(Compiler.java:7379)
... 14 more
Your advice/fix would be much appreciated! Attached are the main Clj. function that has the consumer we're testing (core.clj), and project.clj. Thanks!