Class AvroSharpGlueKafkaExtensions

Namespace

AvroSharp.Aws.Glue.Kafka

Assembly

AvroSharp.Aws.Glue.Kafka.dll

Sets AvroSharp's Glue Schema Registry serializers and deserializers on Confluent.Kafka's producer and consumer builders.

public static class AvroSharpGlueKafkaExtensions

Inheritance

object

AvroSharpGlueKafkaExtensions

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Methods

SetAvroSharpGlueValueDeserializer<TKey, TValue>(ConsumerBuilder<TKey, TValue>, IAmazonGlue, AvroSharpGlueOptions?)

Reads values with AvroSharpGlueKafkaDeserializer<T>. The consumer calls deserializers synchronously, so it waits for the registry the first time each schema version is seen.

SetAvroSharpGlueValueSerializer<TKey, TValue>(ProducerBuilder<TKey, TValue>, IAmazonGlue, AvroSharpGlueOptions?)

Writes values with AvroSharpGlueKafkaSerializer<T>, as its synchronous interface, so both Produce and ProduceAsync work. It waits for Glue the first time each schema is written.