Crate schema_registry_converter

Rust encoders and decoders in order to work with the Confluent schema registry.

This crate contains ways to handle encoding and decoding of messages making use of the confluent schema-registry. This happens in a way that is compatible to the confluent java serde. As a result it becomes easy to work with the same data in both the jvm and rust.

Both the Decoder and the Encoder have a cache to allow re-use of the Schema objects used for the avro transitions.

For Encoding data it's possible to supply a schema else the latest available schema will be used. For Decoding it works the same as the Java part, using the id encoded in the bytes, the correct schema will be fetched and used to decode the message to a avro_rs::types::Value.

Resulting errors are SRCError, besides the error they also contain a .cached which tells whether the error is cached or not. Another property added to the error is retriable, in some cases, like when the network fails it might be worth to retry the same function. The library itself doesn't automatically does retries.

Modules

async_impl
avro_common
blocking
error
proto_raw_common
schema_registry_common	Contains structs, enums' and functions common to async and blocking implementation of schema registry. So stuff dealing with the responses from schema registry, determining the subject, etc.