schema-registry-dotnet

.Net wrapper for the Confluent Schema Registry REST API. Nuget package: https://www.nuget.org/packages/SchemaRegistry/

REST API usage:

using (var registry = new SchemaRegistryApi("http://schema-registry.my-company.com"))
{
    // Get first 10 subjects
    var subjects = registry.GetAllSubjects().Result.Take(10);
    Console.WriteLine("First 10 subjects: " + String.Join(", ", subjects));

    // Get last schema by subject
    var subject = subjects.First();
    var meta = registry.GetLatestSchemaMetadata(subject).Result;
    Console.WriteLine($"Last version of the {subject} subject: {meta.Version}");

    // Check schema compatibiliy
    var isCompatible = registry.TestCompatibility(subject, meta.Schema).Result;
    Console.WriteLine($"Is the schema compatible to itself: {isCompatible}");

    // Register the schema (returns the same ID for identical schema)
    var newSchemaId = registry.Register(subject, meta.Schema).Result;
    Console.WriteLine($"Schema id: {newSchemaId}");
}

There's also RegistryAwareSerializer class, which implements Confluent's AVRO+Schema registry convention.

On serialize:

Access Schema Registry to check Schema compatibility and get Schema ID (statically cached)
Write prefix containing the 0 magic byte and the schema ID to the message

On deserialize:

Reads message prefix to check magic 0 byte and extract Schema ID
Access Schema Registry to get Schema
Provides retrieved schema as Writer Schema to the serializer

AVRO serializer implementation is pluggable. Example implementation for Confluent Apache AVRO library is included in tests

jpsilvagallino/schema-registry-dotnet

schema-registry-dotnet