Class JsonSchemaRegistryMessageSerializer<TMessage>

Namespace

Silverback.Messaging.Serialization

Assembly

Silverback.Integration.Kafka.SchemaRegistry.dll

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

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

Type Parameters

TMessage

The type of the messages to be serialized.

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()

Constructors

JsonSchemaRegistryMessageSerializer(ISchemaRegistryClient, JsonSerializerConfig?, NewtonsoftJsonSchemaGeneratorSettings?)

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

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

Parameters

schemaRegistryClient ISchemaRegistryClient

The schema registry client.

jsonSerializerConfig JsonSerializerConfig

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

jsonSchemaGeneratorSettings NewtonsoftJsonSchemaGeneratorSettings

The JSON schema generator settings.

Properties

JsonSchemaGeneratorSettings

Gets the JSON schema generator settings.

public JsonSchemaGeneratorSettings? JsonSchemaGeneratorSettings { get; }

Property Value

JsonSchemaGeneratorSettings

JsonSerializerConfig

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

public JsonSerializerConfig? JsonSerializerConfig { get; }

Property Value

JsonSerializerConfig