Class ProtobufMessageSerializer<TMessage>

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

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

The type of the messages to be serialized.

Constructors

ProtobufMessageSerializer(ISchemaRegistryClient, ProtobufSerializerConfig?)

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

Declaration
public ProtobufMessageSerializer(ISchemaRegistryClient schemaRegistryClient, ProtobufSerializerConfig? protobufSerializerConfig = null)
Parameters
Type Name Description
ISchemaRegistryClient schemaRegistryClient

The schema registry client.
ProtobufSerializerConfig protobufSerializerConfig

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

Properties

ProtobufSerializerConfig

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

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

Implements