Class AvroMessageSerializer<TMessage>

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

Inheritance
System.Object
AvroMessageSerializerBase
AvroMessageSerializer<TMessage>
Inherited Members
System.Object.Equals(System.Object)
System.Object.Equals(System.Object, System.Object)
System.Object.GetHashCode()
System.Object.GetType()
System.Object.MemberwiseClone()
System.Object.ReferenceEquals(System.Object, System.Object)
System.Object.ToString()
Namespace: Silverback.Messaging.Serialization
Assembly: Silverback.Integration.Kafka.SchemaRegistry.dll
Syntax
public class AvroMessageSerializer<TMessage> : AvroMessageSerializerBase, IKafkaMessageSerializer, IMessageSerializer where TMessage : class
Type Parameters
Name Description
TMessage

The type of the messages to be serialized and/or deserialized.

Methods

| Improve this doc View source

DeserializeAsync(Stream, MessageHeaderCollection, MessageSerializationContext)

Declaration
public override async ValueTask<(object Message, Type MessageType)> DeserializeAsync(Stream messageStream, MessageHeaderCollection messageHeaders, MessageSerializationContext context)
Parameters
Type Name Description
System.IO.Stream messageStream
MessageHeaderCollection messageHeaders
MessageSerializationContext context
Returns
Type Description
System.Threading.Tasks.ValueTask<System.ValueTuple<System.Object, System.Type>>
Overrides
| Improve this doc View source

DeserializeKey(Byte[], IReadOnlyCollection<MessageHeader>, MessageSerializationContext)

Declaration
public override string DeserializeKey(byte[] key, IReadOnlyCollection<MessageHeader> messageHeaders, MessageSerializationContext context)
Parameters
Type Name Description
System.Byte[] key
System.Collections.Generic.IReadOnlyCollection<MessageHeader> messageHeaders
MessageSerializationContext context
Returns
Type Description
System.String
Overrides
| Improve this doc View source

SerializeAsync(Object, MessageHeaderCollection, MessageSerializationContext)

Declaration
public override async ValueTask<Stream> SerializeAsync(object message, MessageHeaderCollection messageHeaders, MessageSerializationContext context)
Parameters
Type Name Description
System.Object message
MessageHeaderCollection messageHeaders
MessageSerializationContext context
Returns
Type Description
System.Threading.Tasks.ValueTask<System.IO.Stream>
Overrides
| Improve this doc View source

SerializeKey(String, IReadOnlyCollection<MessageHeader>, MessageSerializationContext)

Declaration
public override byte[] SerializeKey(string key, IReadOnlyCollection<MessageHeader> messageHeaders, MessageSerializationContext context)
Parameters
Type Name Description
System.String key
System.Collections.Generic.IReadOnlyCollection<MessageHeader> messageHeaders
MessageSerializationContext context
Returns
Type Description
System.Byte[]
Overrides

Implements