Clojurians Log v2
Clojure programming
Channels
Apps
jackdaw
Ben Davies 2022-08-03T14:29:54.205469Z
Hey folks I’m looking to change my kafka streams application to use a custom partitioner on the https://kafka.apache.org/21/javadoc/org/apache/kafka/streams/kstream/KStream.html#to-java.lang.String-org.apache.kafka.streams.kstream.Produced- method of my topology. When I try and implement this using jackdaw I get this error
Uncaught exception, not in assertion
error: clojure.lang.ArityException: Wrong number of args (3) passed to: jackdaw.streams/tojackdaw.streams/to doesn’t accept a https://kafka.apache.org/23/javadoc/index.html?org/apache/kafka/streams/kstream/Produced.html interface. I’ve tried to do some java interop but because Jackdaw refactors the methods into functions I end up with the wrong args passed in this way as well. Is there a way of blending java interop with a jackdaw topology to get around this?
Alastair Hole 2022-08-03T16:24:16.511829Z
Unfortunately the API docs seem to have been broken for a while, I’m not sure if there would be some answers there https://cljdoc.org/builds/60148
Alastair Hole 2022-08-03T16:24:30.242279Z
This project seems rather quiet these days alas
Ben Davies 2022-08-03T16:25:18.269399Z
I’m using an older version of Jackdaw 0.7.6 and have found the kstream* fn which does return the underlying object https://cljdoc.org/d/fundingcircle/jackdaw/0.7.6/api/jackdaw.streams#kstream*
Alastair Hole 2022-08-03T16:25:49.234659Z
Ah good spot, that sounds promising