Class AvroSharpGlueKafkaDeserializer<T>

Namespace

AvroSharp.Aws.Glue.Kafka

Assembly

AvroSharp.Aws.Glue.Kafka.dll

A Confluent.Kafka deserializer of AWS Glue Schema Registry's wire format, on AvroSharpGlueSerializer, as AWS's GlueSchemaRegistryKafkaDeserializer.

public sealed class AvroSharpGlueKafkaDeserializer<T> : IAsyncDeserializer<T>, IDeserializer<T>

Type Parameters

T

The type read: a type AvroTypes knows, GenericRecord or AvroValue.

Inheritance

object

AvroSharpGlueKafkaDeserializer<T>

Implements

IAsyncDeserializer<T>

IDeserializer<T>

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.ReferenceEquals(object, object)

object.ToString()

Remarks

It is both asynchronous and synchronous. Confluent.Kafka's consumer takes synchronous deserializers, which wait for Glue the first time each schema version is read.

Constructors

AvroSharpGlueKafkaDeserializer(IAmazonGlue, AvroSharpGlueOptions?)

Creates a deserializer.

AvroSharpGlueKafkaDeserializer(AvroSharpGlueSerializer)

Creates a deserializer on serializer, sharing its caches.

Methods

Deserialize(ReadOnlySpan<byte>, bool, SerializationContext)

Reads a value, waiting for Glue when its schema version isn't known yet. A tombstone reads as null; it can't be read as a value type.

DeserializeAsync(ReadOnlyMemory<byte>, bool, SerializationContext)

Reads a value. A tombstone reads as null; it can't be read as a value type.