Class AvroMessageSerializer<TMessage>

Connects to the specified schema registry and serializes the messages in Apache Avro format.

Inheritance

object

SchemaRegistryMessageSerializer<TMessage>

AvroMessageSerializer<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 AvroMessageSerializer<TMessage> : SchemaRegistryMessageSerializer<TMessage>, IMessageSerializer where TMessage : class

Type Parameters

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

Constructors

AvroMessageSerializer(ISchemaRegistryClient, AvroSerializerConfig?)

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

Declaration

public AvroMessageSerializer(ISchemaRegistryClient schemaRegistryClient, AvroSerializerConfig? avroSerializerConfig = null)

Parameters

Type	Name	Description
ISchemaRegistryClient	schemaRegistryClient	The schema registry client.
AvroSerializerConfig	avroSerializerConfig	The Confluent.SchemaRegistry.Serdes.AvroSerializer<T> configuration.

Properties

AvroSerializerConfig

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

Declaration

public AvroSerializerConfig? AvroSerializerConfig { get; }

Property Value

Type	Description
AvroSerializerConfig

Implements

IMessageSerializer