Class AvroSharpKafkaFlowSerializer

Namespace

AvroSharp.KafkaFlow

Assembly

AvroSharp.KafkaFlow.dll

KafkaFlow's KafkaFlow.ISerializer on AvroSharpSerializer<T>: writes each message, of any type AvroTypes knows, in Confluent Schema Registry framing, with one serializer per type. The bytes are those of KafkaFlow's Confluent Avro serializer for the same schema and value.

public sealed class AvroSharpKafkaFlowSerializer : ISerializer

Inheritance

object

AvroSharpKafkaFlowSerializer

Implements

ISerializer

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.ReferenceEquals(object, object)

object.ToString()

Remarks

Usually added with AddSchemaRegistryAvroSharpSerializer(IProducerMiddlewareConfigurationBuilder, AvroSharpSerializerConfig?).

Constructors

AvroSharpKafkaFlowSerializer(ISchemaRegistryClient, AvroSharpSerializerConfig?)

Creates a serializer.

Methods

SerializeAsync(object, Stream, ISerializerContext)

Writes a message: its schema ID, registered or looked up once per type and subject, then its Avro encoding.