Class JsonSchemaRegistryMessageDeserializer<TMessage>

Namespace

Silverback.Messaging.Serialization

Assembly

Silverback.Integration.Kafka.SchemaRegistry.dll

Connects to the specified schema registry and deserializes the JSON messages into an instance of TMessage.

public class JsonSchemaRegistryMessageDeserializer<TMessage> : SchemaRegistryMessageDeserializer<TMessage>, IMessageDeserializer where TMessage : class

Type Parameters

TMessage

The type of the messages to be deserialized.

Inheritance

object

SchemaRegistryMessageDeserializer<TMessage>

JsonSchemaRegistryMessageDeserializer<TMessage>

Implements

IMessageDeserializer

Inherited Members

SchemaRegistryMessageDeserializer<TMessage>.DeserializeAsync(Stream, MessageHeaderCollection, ConsumerEndpoint)

SchemaRegistryMessageDeserializer<TMessage>.RequireHeaders

SchemaRegistryMessageDeserializer<TMessage>.SchemaRegistryClient

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Constructors

JsonSchemaRegistryMessageDeserializer(ISchemaRegistryClient, JsonDeserializerConfig?, NewtonsoftJsonSchemaGeneratorSettings?)

Initializes a new instance of the JsonSchemaRegistryMessageDeserializer<TMessage> class.

public JsonSchemaRegistryMessageDeserializer(ISchemaRegistryClient schemaRegistryClient, JsonDeserializerConfig? jsonDeserializerConfig = null, NewtonsoftJsonSchemaGeneratorSettings? jsonSchemaGeneratorSettings = null)

Parameters

schemaRegistryClient ISchemaRegistryClient

The schema registry client.

jsonDeserializerConfig JsonDeserializerConfig

The Confluent.SchemaRegistry.Serdes.JsonSerializer<T> configuration.

jsonSchemaGeneratorSettings NewtonsoftJsonSchemaGeneratorSettings

The JSON schema generator settings.

Properties

JsonDeserializerConfig

Gets the Confluent.SchemaRegistry.Serdes.JsonDeserializer<T> configuration.

public JsonDeserializerConfig? JsonDeserializerConfig { get; }

Property Value

JsonDeserializerConfig

JsonSchemaGeneratorSettings

Gets the JSON schema generator settings.

public NewtonsoftJsonSchemaGeneratorSettings? JsonSchemaGeneratorSettings { get; }

Property Value

NewtonsoftJsonSchemaGeneratorSettings

Methods

GetCompatibleSerializer()

Gets a new IMessageSerializer compatible with this deserializer.

public override IMessageSerializer GetCompatibleSerializer()

Returns

IMessageSerializer

A new instance of an IMessageSerializer compatible with this deserializer.