cddr.kafka.test.serde — cddr/test-machine 1.0.1-1-gcbb4695

apply-deserializers clj

(apply-deserializers deserializers m)

apply-serializers clj

(apply-serializers serializers m)

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)

serde-map clj

(serde-map 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})

serializer clj

(serializer topic)

Serializes a message.

serializers clj

(serializers topic-config)

Returns a map of topic to the corresponding serializer