jackdaw

https://github.com/FundingCircle/jackdaw
Bryan 2020-10-06T17:36:09.016400Z

maybe dumb question… in the following code (that creates a cached registry client to talk to confluent), where does RestService. come from? Pretty sure I’m missing an import but no idea which one. Code came from https://clojurians-log.clojureverse.org/jackdaw/2019-05-17 (@billh ?)

(defn cached-schema-registry-cli []
  (let [restService (RestService. "")]
    (CachedSchemaRegistryClient. restService 10 (doto (new java.util.HashMap) (.put "basic.auth.credentials.source" "URL")))))

(def serde-resolver
  (partial resolver/serde-resolver :schema-registry-url "" :schema-registry-client (cached-schema-registry-cli)))

dakra 2020-10-07T12:07:07.016700Z

Maybe useful for you. I saw that there's an open PR that adds support for schema registry basic auth https://github.com/FundingCircle/jackdaw/pull/265

👍 2
Bryan 2020-10-06T17:51:09.016500Z

nevermind, finally answered my own questtion. For anyone else coming behind me on this, the two classpaths I was missing are:

io.confluent.kafka.schemaregistry.client.rest.RestService.
io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient.