rust-schema-registry-client

A fully asynchronous Rust client library for interacting with the Confluent Schema Registry.

The library

rust-schema-registry-client provides a Schema Registry client, along with serdes (serializers/deserializers) for Avro, Protobuf, and JSON Schema.

Features

• Support for Avro, Protobuf, and JSON Schema formats
• Data quality rules using Google Common Expression Language (CEL) expressions
• Schema migration rules using JSONata expressions
• Client-side field-level encryption (CSFLE) rules using AWS KMS, Azure Key Vault, Google Cloud KMS, or HashiCorp Vault

This library can be used with rust-rdkafka but does not depend on it.

Serdes

• AvroSerializer and AvroDeserializer - serdes that use apache-avro
• ProtobufSerializer and ProtobufDeserializer - serdes that use prost and prost-reflect
• JsonSerializer and JsonDeserializer - serdes that use jsonschema

Installation

Add this to your Cargo.toml:

[dependencies]
schema-registry-client = { version = "0.2.1" }

The following features are available:

• rules-cel - enables data quality rules using CEL
• rules-encryption-awskms - enables CSFLE rules using AWS KMS
• rules-encryption-azurekms - enables CSFLE rules using Azure Key Vault
• rules-encryption-gcpkms - enables CSFLE rules using Google Cloud KMS
• rules-encryption-hcvault - enables CSFLE rules using HashiCorp Vault
• rules-encryption-localkms - enables CSFLE rules using a local KMS (for testing)
• rules-jsonata - enables schema migration rules using JSONata

For example, to use CSFLE with the AWS KMS, add this to your Cargo.toml:

[dependencies]
schema-registry-client = { version = "0.2.1", features = ["rules", "rules-encryption-awskms"] }

Examples

You can find examples in the examples folder. To run them:

cargo run --example <example_name> -- <example_args>

Further information can be found in this blog.