Class ProtobufMessageDeserializer<TMessage>

Namespace

Silverback.Messaging.Serialization

Assembly

Silverback.Integration.Kafka.SchemaRegistry.dll

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

public class ProtobufMessageDeserializer<TMessage> : SchemaRegistryMessageDeserializer<TMessage>, IMessageDeserializer where TMessage : class, IMessage<TMessage>, new()

Type Parameters

TMessage

The type of the messages to be deserialized.

Inheritance

object

SchemaRegistryMessageDeserializer<TMessage>

ProtobufMessageDeserializer<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

ProtobufMessageDeserializer(ISchemaRegistryClient, ProtobufDeserializerConfig?)

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

public ProtobufMessageDeserializer(ISchemaRegistryClient schemaRegistryClient, ProtobufDeserializerConfig? protobufDeserializerConfig = null)

Parameters

schemaRegistryClient ISchemaRegistryClient

The schema registry client.

protobufDeserializerConfig ProtobufDeserializerConfig

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

Properties

ProtobufDeserializerConfig

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

public ProtobufDeserializerConfig? ProtobufDeserializerConfig { get; }

Property Value

ProtobufDeserializerConfig

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.