Class ProtobufMessageSerializer<TMessage>

Namespace

Silverback.Messaging.Serialization

Assembly

Silverback.Integration.Kafka.SchemaRegistry.dll

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

public class ProtobufMessageSerializer<TMessage> : SchemaRegistryMessageSerializer<TMessage>, IMessageSerializer where TMessage : class, IMessage<TMessage>, new()

Type Parameters

TMessage

The type of the messages to be serialized.

Inheritance

object

SchemaRegistryMessageSerializer<TMessage>

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

ProtobufMessageSerializer(ISchemaRegistryClient, ProtobufSerializerConfig?)

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

public ProtobufMessageSerializer(ISchemaRegistryClient schemaRegistryClient, ProtobufSerializerConfig? protobufSerializerConfig = null)

Parameters

schemaRegistryClient ISchemaRegistryClient

The schema registry client.

protobufSerializerConfig ProtobufSerializerConfig

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

Properties

ProtobufSerializerConfig

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

public ProtobufSerializerConfig? ProtobufSerializerConfig { get; }

Property Value

ProtobufSerializerConfig