Class AvroMessageDeserializer<TMessage>

Namespace

Silverback.Messaging.Serialization

Assembly

Silverback.Integration.Kafka.SchemaRegistry.dll

Connects to the specified schema registry and deserializes the messages from Apache Avro format.

public class AvroMessageDeserializer<TMessage> : SchemaRegistryMessageDeserializer<TMessage>, IMessageDeserializer where TMessage : class

Type Parameters

TMessage

The type of the messages to be deserialized.

Inheritance

object

SchemaRegistryMessageDeserializer<TMessage>

AvroMessageDeserializer<TMessage>

Implements

IMessageDeserializer

Inherited Members

SchemaRegistryMessageDeserializer<TMessage>.DeserializeAsync(Stream, MessageHeaderCollection, ConsumerEndpoint)

SchemaRegistryMessageDeserializer<TMessage>.RequireHeaders

SchemaRegistryMessageDeserializer<TMessage>.SchemaRegistryClient

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Constructors

AvroMessageDeserializer(ISchemaRegistryClient, AvroDeserializerConfig?)

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

public AvroMessageDeserializer(ISchemaRegistryClient schemaRegistryClient, AvroDeserializerConfig? avroDeserializerConfig = null)

Parameters

schemaRegistryClient ISchemaRegistryClient

The schema registry client.

avroDeserializerConfig AvroDeserializerConfig

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

Properties

AvroDeserializerConfig

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

public AvroDeserializerConfig? AvroDeserializerConfig { get; }

Property Value

AvroDeserializerConfig

Methods

GetCompatibleSerializer()

Gets a new IMessageSerializer compatible with this deserializer.

public override IMessageSerializer GetCompatibleSerializer()

Returns

IMessageSerializer

A new instance of an IMessageSerializer compatible with this deserializer.