Class AvroMessageSerializer<TMessage>

Namespace

Silverback.Messaging.Serialization

Assembly

Silverback.Integration.Kafka.SchemaRegistry.dll

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

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

Type Parameters

TMessage

The type of the messages to be serialized.

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

Constructors

AvroMessageSerializer(ISchemaRegistryClient, AvroSerializerConfig?)

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

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

Parameters

schemaRegistryClient ISchemaRegistryClient

The schema registry client.

avroSerializerConfig AvroSerializerConfig

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

Properties

AvroSerializerConfig

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

public AvroSerializerConfig? AvroSerializerConfig { get; }

Property Value

AvroSerializerConfig