Fork me on GitHub
Slack Archive

This page is not created by, affiliated with, or supported by Slack Technologies, Inc.

2020-10-06

Channels

#jackdaw
<
2020-10-06
>
Bryan17:10:09

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)))

Bryan17:10:09

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.

dakra12:10:07

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

👍 6