Class JsonSchemaRegistryMessageSerializer<TMessage>

Connects to the specified schema registry and serializes the messages as JSON.

Inheritance

object

SchemaRegistryMessageSerializer<TMessage>

JsonSchemaRegistryMessageSerializer<TMessage>

Implements

IMessageSerializer

Inherited Members

SchemaRegistryMessageSerializer<TMessage>.SerializeAsync(object, MessageHeaderCollection, ProducerEndpoint)

SchemaRegistryMessageSerializer<TMessage>.SchemaRegistryClient

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Namespace: Silverback.Messaging.Serialization

Assembly: Silverback.Integration.Kafka.SchemaRegistry.dll

Syntax

public class JsonSchemaRegistryMessageSerializer<TMessage> : SchemaRegistryMessageSerializer<TMessage>, IMessageSerializer where TMessage : class

Type Parameters

Name	Description
TMessage	The type of the messages to be serialized.

Constructors

JsonSchemaRegistryMessageSerializer(ISchemaRegistryClient, JsonSerializerConfig?, NewtonsoftJsonSchemaGeneratorSettings?)

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

Declaration

public JsonSchemaRegistryMessageSerializer(ISchemaRegistryClient schemaRegistryClient, JsonSerializerConfig? jsonSerializerConfig = null, NewtonsoftJsonSchemaGeneratorSettings? jsonSchemaGeneratorSettings = null)

Parameters

Type	Name	Description
ISchemaRegistryClient	schemaRegistryClient	The schema registry client.
JsonSerializerConfig	jsonSerializerConfig	The Confluent.SchemaRegistry.Serdes.JsonSerializer<T> configuration.
NewtonsoftJsonSchemaGeneratorSettings	jsonSchemaGeneratorSettings	The JSON schema generator settings.

Properties

JsonSchemaGeneratorSettings

Gets the JSON schema generator settings.

Declaration

public JsonSchemaGeneratorSettings? JsonSchemaGeneratorSettings { get; }

Property Value

Type	Description
JsonSchemaGeneratorSettings

JsonSerializerConfig

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

Declaration

public JsonSerializerConfig? JsonSerializerConfig { get; }

Property Value

Type	Description
JsonSerializerConfig

Implements

IMessageSerializer