jackdaw.test.serde

apply-deserializers

(apply-deserializers deserializers m)

apply-serializers

(apply-serializers serializers m)

byte-array-deserializer

byte-array-serde

Byte-array key and value serde.

byte-array-serializer

deserialize-key

(deserialize-key k {topic-name :topic-name, key-serde :key-serde})
Deserializes a key.

deserialize-value

(deserialize-value v {topic-name :topic-name, value-serde :value-serde})
Deserializes a value.

deserializer

(deserializer topic)
Deserializes a message.

deserializers

(deserializers topic-config)
Returns a map of topics to the corresponding deserializer

resolver

(resolver topic-config)

serde-map

(serde-map topic-config)

serialize-key

(serialize-key k {topic-name :topic-name, key-serde :key-serde, :as t})
Serializes a key.

serialize-value

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

serializer

(serializer topic)
Serializes a message.

serializers

(serializers topic-config)
Returns a map of topic to the corresponding serializer