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

Schema management for Kafka messages

all-of clj

(all-of & schema-ids)

Create a predicate that validates against all of the given schemas

any-of clj

(any-of & schema-ids)

Create a predicate that validates against any of the given schemas

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

explain-validation-for-topic clj

(explain-validation-for-topic message topic-name)

Get detailed validation explanation for a topic's schema

get-schema clj

(get-schema schema-id)

Get a registered schema

get-schema-for-topic clj

(get-schema-for-topic topic-name)

Get a schema for a specific topic.

Looks for schemas in this order:

1. :topic-name/default
2. :topic-name (direct topic schema)

Examples:

• (get-schema-for-topic "users") -> looks for :users/default or :users

list-schemas clj

(list-schemas)

List all registered schemas

list-schemas-for-topic clj

(list-schemas-for-topic topic-name)

List all schemas registered for a specific topic

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

schema-ref clj

(schema-ref schema-id)

Create a reference to another schema for validation

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

validate-message-for-topic clj

(validate-message-for-topic message topic-name)

Validate a message against a topic's schema.

Automatically looks for topic-scoped schemas:

• (validate-message-for-topic message "users") -> uses :users/default or :users

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