jackdaw.test.serde — net.clojars.savya/jackdaw 1.3.3

apply-deserializers clj

(apply-deserializers deserializers m)

Deserializes record m using the deserializer registered for its topic in deserializers; throws IllegalArgumentException for an unknown topic.

apply-serializers clj

(apply-serializers serializers m)

Serializes message m using the serializer registered for its topic in serializers; throws IllegalArgumentException for an unknown topic.

byte-array-deserializer clj

byte-array-serde clj

Byte-array key and value serde.

byte-array-serializer clj

deserialize-key clj

(deserialize-key k {topic-name :topic-name key-serde :key-serde})

Deserializes a key.

deserialize-value clj

(deserialize-value v {topic-name :topic-name value-serde :value-serde})

Deserializes a value.

deserializer clj

(deserializer topic)

Deserializes a message.

deserializers clj

(deserializers topic-config)

Returns a map of topics to the corresponding deserializer

resolver clj

(resolver topic-config)

Returns a fn that resolves a serde keyword (:edn, :json, :long, :string, ...) in topic-config to a concrete Kafka serde instance.

serde-map clj

(serde-map topic-config)

Returns {:serializers _ :deserializers _}, each a map of topic-name to the corresponding serializer/deserializer fn for topic-config.

serialize-key clj

(serialize-key k {topic-name :topic-name key-serde :key-serde :as t})

Serializes a key.

serialize-value clj

(serialize-value v {topic-name :topic-name value-serde :value-serde :as t})

Serializes value v for topic t using its :value-serde, returning nil when v is nil.

serializer clj

(serializer topic)

Serializes a message.

serializers clj

(serializers topic-config)

Returns a map of topic to the corresponding serializer