Class AvroSharpSerdeExtensions

Namespace

AvroSharp.Confluent

Assembly

AvroSharp.Confluent.dll

Sets AvroSharp serializers and deserializers on Confluent.Kafka's producer and consumer builders, as their synchronous interfaces, so both Produce and ProduceAsync work. They wait for the registry the first time each schema is written or read.

public static class AvroSharpSerdeExtensions

Inheritance

object

AvroSharpSerdeExtensions

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Methods

SetAvroSharpGenericValueDeserializer<TKey>(ConsumerBuilder<TKey, AvroValue>, ISchemaRegistryClient, AvroSchema?, AvroSharpDeserializerConfig?, RuleRegistry?)

Reads generic values (AvroValue): each message in its writer's schema, or resolved to readerSchema (CreateDeserializer(ISchemaRegistryClient, AvroSchema?, AvroSharpDeserializerConfig?, RuleRegistry?)).

SetAvroSharpGenericValueSerializer<TKey>(ProducerBuilder<TKey, AvroValue>, ISchemaRegistryClient, AvroSchema?, AvroSharpSerializerConfig?, RuleRegistry?)

Writes generic values (AvroValue): of schema, or, without one, each record with its own schema (AvroSharpGeneric).

SetAvroSharpKeyDeserializer<TKey, TValue>(ConsumerBuilder<TKey, TValue>, ISchemaRegistryClient, AvroSharpDeserializerConfig?, RuleRegistry?)

Reads keys with an AvroSharpDeserializer<T> of TKey, which AvroTypes knows.

SetAvroSharpKeySerializer<TKey, TValue>(ProducerBuilder<TKey, TValue>, ISchemaRegistryClient, AvroSharpSerializerConfig?, RuleRegistry?)

Writes keys with an AvroSharpSerializer<T> of TKey, which AvroTypes knows.

SetAvroSharpValueDeserializer<TKey, TValue>(ConsumerBuilder<TKey, TValue>, ISchemaRegistryClient, AvroSharpDeserializerConfig?, RuleRegistry?)

Reads values with an AvroSharpDeserializer<T> of TValue, which AvroTypes knows.

SetAvroSharpValueSerializer<TKey, TValue>(ProducerBuilder<TKey, TValue>, ISchemaRegistryClient, AvroSharpSerializerConfig?, RuleRegistry?)

Writes values with an AvroSharpSerializer<T> of TValue, which AvroTypes knows.