kafka-metamorphosis.schema — org.clojars.caioclavico/kafka-metamorphosis 0.2.0

Schema management for Kafka messages

consume-schema-messages! clj

(consume-schema-messages! group-id topics schema-id)

(consume-schema-messages! group-id topics schema-id opts)

Consume messages with schema validation.

defschema clj

(defschema schema-id spec-map)

Define and register a schema with the given ID and specification map.

Returns the schema ID.

explain-validation clj

(explain-validation message schema-id)

Get detailed validation explanation

get-schema clj

(get-schema schema-id)

Get a registered schema

list-schemas clj

(list-schemas)

List all registered schemas

map-of clj

(map-of key-pred value-pred)

Create a predicate for maps with specific key-value predicates

max-count clj

(max-count n)

Create a predicate for maximum collection size

min-count clj

(min-count n)

Create a predicate for minimum collection size

one-of clj

(one-of & values)

Create a predicate that accepts one of the given values

send-schema-message! clj

(send-schema-message! topic value schema-id)

(send-schema-message! topic key value schema-id)

(send-schema-message! topic key value schema-id producer-opts)

Send a message validated against a schema.

validate-message clj

(validate-message message schema-id)

Validate a message against a schema

with-schema-deserialization clj

(with-schema-deserialization deserializers schema-id)

Wrap deserializers with schema validation

with-schema-serializers clj

(with-schema-serializers serializers schema-id)

Wrap serializers with schema validation