Clojurians Log v2
jackdaw
There seems to be a breaking change from io.confluent
[io.confluent/kafka-schema-registry-client "5.1.2"
:exclusions [com.fasterxml.jackson.core/jackson-databind]]
[io.confluent/kafka-avro-serializer "5.1.2"]
5.1.2 does not exist on maven central anymore? I can't install Jackdaw anymore.Looks like they decided to change the version number to "3.3.1"
wtf?! that would be a new and fun way of breaking users' applications. Looking into it. How did you determine 5.1.2 had changed to 3.3.1?
I think it can't be deliberate. The docs still reference 5.1.2
I looked at maven central
one sec
https://mvnrepository.com/artifact/io.confluent/kafka-schema-registry-client
it's under Compile Dependencies of https://mvnrepository.com/artifact/fundingcircle/jackdaw/0.6.4
I wonder how that is populated.
curl <http://packages.confluent.io/maven/io/confluent/kafka-schema-registry-client/5.1.2/kafka-schema-registry-client-5.1.2.jar> > /tmp/kafka-schema-registry-client-5.1.2.jar seems to work fine.
Hmm. wierd, I got Error building classpath. Could not find artifact io.confluent:kafka-schema-registry-client:jar:5.1.2 in central (<https://repo1.maven.org/maven2/>) when trying to fetch jackdaw with deps.edn
Do you have their repo in your project.clj?
:repositories [["confluent" {:url "<https://packages.confluent.io/maven/>"}]]
Ah sorry, you're using deps
I think deps has it's own way of doing this.
:mvn/repos
{"confluent" {:url "<https://packages.confluent.io/maven/>"}}
Ah, very sorry if I gave you an heart attack. False alarm 😣
(Playing around with deps.edn for the first time.)
Yes, I use deps, you have to put the confluent repo in 😉
😅
I figured something out. If I want to see some nice examples of using jackdaw I can always look at the tests 😁
Has anyone gotten headers working in the produce! function? in the test-code there's an empty map as headers but if I pass in a non-empty map I get exceptions.
class clojure.lang.MapEntry cannot be cast to class org.apache.kafka.common.header.Header
I found a solution