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.