Class AsyncSerializer<T, TParsedSchema>

Inheritance
object
AsyncSerde<TParsedSchema>
AsyncSerializer<T, TParsedSchema>
JsonSerializer<T>
ProtobufSerializer<T>
Implements
Inherited Members
Namespace: Confluent.SchemaRegistry
Assembly: Confluent.SchemaRegistry.dll
Syntax
public abstract class AsyncSerializer<T, TParsedSchema> : AsyncSerde<TParsedSchema>, IAsyncSerializer<T>
Type Parameters
NameDescription
T
TParsedSchema

Constructors

AsyncSerializer(ISchemaRegistryClient, SerdeConfig, RuleRegistry)

Declaration
protected AsyncSerializer(ISchemaRegistryClient schemaRegistryClient, SerdeConfig config, RuleRegistry ruleRegistry = null)
Parameters
TypeNameDescription
ISchemaRegistryClientschemaRegistryClient
SerdeConfigconfig
RuleRegistryruleRegistry

Fields

autoRegisterSchema

Declaration
protected bool autoRegisterSchema
Field Value
TypeDescription
bool

initialBufferSize

Declaration
protected int initialBufferSize
Field Value
TypeDescription
int

normalizeSchemas

Declaration
protected bool normalizeSchemas
Field Value
TypeDescription
bool

schemaIdEncoder

Declaration
protected ISchemaIdEncoder schemaIdEncoder
Field Value
TypeDescription
ISchemaIdEncoder

subjectsRegistered

Declaration
protected HashSet<string> subjectsRegistered
Field Value
TypeDescription
HashSet<string>

Methods

SerializeAsync(T, SerializationContext)

Serialize the key or value of a Message<TKey, TValue> instance.

Declaration
public abstract Task<byte[]> SerializeAsync(T value, SerializationContext context)
Parameters
TypeNameDescription
Tvalue
SerializationContextcontext

Context relevant to the serialize operation.

Returns
TypeDescription
Task<byte[]>

A Task that completes with the serialized data.

Implements