Class JsonSchemaRegistryMessageDeserializer<TMessage>

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

Inheritance
object
SchemaRegistryMessageDeserializer<TMessage>
JsonSchemaRegistryMessageDeserializer<TMessage>
Inherited Members
Namespace: Silverback.Messaging.Serialization
Assembly: Silverback.Integration.Kafka.SchemaRegistry.dll
Syntax
public class JsonSchemaRegistryMessageDeserializer<TMessage> : SchemaRegistryMessageDeserializer<TMessage>, IMessageDeserializer where TMessage : class
Type Parameters
Name Description
TMessage

The type of the messages to be deserialized.

Constructors

JsonSchemaRegistryMessageDeserializer(ISchemaRegistryClient, JsonDeserializerConfig?, NewtonsoftJsonSchemaGeneratorSettings?)

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

Declaration
public JsonSchemaRegistryMessageDeserializer(ISchemaRegistryClient schemaRegistryClient, JsonDeserializerConfig? jsonDeserializerConfig = null, NewtonsoftJsonSchemaGeneratorSettings? jsonSchemaGeneratorSettings = null)
Parameters
Type Name Description
ISchemaRegistryClient schemaRegistryClient

The schema registry client.
JsonDeserializerConfig jsonDeserializerConfig

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

The JSON schema generator settings.

Properties

JsonDeserializerConfig

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

Declaration
public JsonDeserializerConfig? JsonDeserializerConfig { get; }
Property Value
Type Description
JsonDeserializerConfig

JsonSchemaGeneratorSettings

Gets the JSON schema generator settings.

Declaration
public NewtonsoftJsonSchemaGeneratorSettings? JsonSchemaGeneratorSettings { get; }
Property Value
Type Description
NewtonsoftJsonSchemaGeneratorSettings

Methods

GetCompatibleSerializer()

Gets a new IMessageSerializer compatible with this deserializer.

Declaration
public override IMessageSerializer GetCompatibleSerializer()
Returns
Type Description
IMessageSerializer

A new instance of an IMessageSerializer compatible with this deserializer.
Overrides

Implements