kafka-avro-confluent.schema-registry-client — ovotech/kafka-avro-confluent 2.1.0-4

A client for the Confluent Schema Registry.

->schema-registry-client clj

(->schema-registry-client config-or-client)

Returns an instance of the schema-registry-client

-healthy? clj

(-healthy? config)

-list-subjects clj

(-list-subjects config)

schema-registry-client? clj

(schema-registry-client? x)

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.