kafka-avro-confluent.v2.schema-registry-client — ovotech/kafka-avro-confluent 2.0.1-2

->schema-registry-client clj

(->schema-registry-client config)

Returns an instance of the schema-registry-client

-healthy? clj

(-healthy? config)

-list-subjects clj

(-list-subjects {:schema-registry/keys [base-url username password]
                 :as _config})

SchemaRegistry clj protocol

A Confluent Schema Registry client.

get-config clj

(get-config this)

Returns the Schema Registry configuration map.

get-latest-schema-by-subject clj

(get-latest-schema-by-subject this subject)

Gets the latest Schema for a given subject.

get-schema-by-id clj

(get-schema-by-id this id)

Fetches a Schema by Schema Id.

healthy? clj

(healthy? this)

Can the Schema Registry be contacted, and do its responses look right?

list-subjects clj

(list-subjects this)

List all subjects.

post-schema clj

(post-schema this subject schema)

Posts an Avro Schema. Return the Schema Id.