Class ProtobufMessageDeserializer<TMessage>

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

Inheritance
object
SchemaRegistryMessageDeserializer<TMessage>
ProtobufMessageDeserializer<TMessage>
Inherited Members
Namespace: Silverback.Messaging.Serialization
Assembly: Silverback.Integration.Kafka.SchemaRegistry.dll
Syntax
public class ProtobufMessageDeserializer<TMessage> : SchemaRegistryMessageDeserializer<TMessage>, IMessageDeserializer where TMessage : class, IMessage<TMessage>, new()
Type Parameters
Name Description
TMessage

The type of the messages to be deserialized.

Constructors

ProtobufMessageDeserializer(ISchemaRegistryClient, ProtobufDeserializerConfig?)

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

Declaration
public ProtobufMessageDeserializer(ISchemaRegistryClient schemaRegistryClient, ProtobufDeserializerConfig? protobufDeserializerConfig = null)
Parameters
Type Name Description
ISchemaRegistryClient schemaRegistryClient

The schema registry client.
ProtobufDeserializerConfig protobufDeserializerConfig

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

Properties

ProtobufDeserializerConfig

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

Declaration
public ProtobufDeserializerConfig? ProtobufDeserializerConfig { get; }
Property Value
Type Description
ProtobufDeserializerConfig

Methods

GetCompatibleSerializer()

Gets a new IMessageSerializer compatible with this deserializer.

Declaration
public override IMessageSerializer GetCompatibleSerializer()
Returns
Type Description
IMessageSerializer

A new instance of an IMessageSerializer compatible with this deserializer.
Overrides

Implements