franzy.serialization.transit.deserializers

->TransitDeserializer

(->TransitDeserializer format opts)

Positional factory function for class franzy.serialization.transit.deserializers.TransitDeserializer.

transit-deserializer

(transit-deserializer)(transit-deserializer format)(transit-deserializer format opts)

Transit deserializer for Apache Kafka. Use for deserializing Kafka keys and values.

You should pass a format keyword to speciy which Transit-supported format you used when serializing. Valid formats per Transit are :json, :json-verbose, and :msgpack. The default format will be :json (JSON) if no format is passed.

Note: If you use msgpack format, is your responsibility to decode the returned msgpack accordingly. This project does not introduce any msgpack dependencies. This can be wrapped by composing with a msgpack deserialzer.

Note: You may pass any of the built-in Transit options to parse-stream via the opts map. :handlers and :default-handlers are supported options by Transit.

See https://github.com/cognitect/transit-clj