Class AsyncSerializer<T, TParsedSchema>

Inheritance

object

AsyncSerde<TParsedSchema>

AsyncSerializer<T, TParsedSchema>

JsonSerializer<T>

ProtobufSerializer<T>

Implements

IAsyncSerializer<T>

Inherited Members

AsyncSerde<TParsedSchema>.schemaRegistryClient

AsyncSerde<TParsedSchema>.ruleRegistry

AsyncSerde<TParsedSchema>.useSchemaId

AsyncSerde<TParsedSchema>.useLatestVersion

AsyncSerde<TParsedSchema>.latestCompatibilityStrict

AsyncSerde<TParsedSchema>.useLatestWithMetadata

AsyncSerde<TParsedSchema>.subjectNameStrategy

AsyncSerde<TParsedSchema>.serdeMutex

AsyncSerde<TParsedSchema>.GetSubjectName(string, bool, string)

AsyncSerde<TParsedSchema>.GetWriterSchema(string, SchemaId, string)

AsyncSerde<TParsedSchema>.GetParsedSchema(Schema)

AsyncSerde<TParsedSchema>.ParseSchema(Schema)

AsyncSerde<TParsedSchema>.ResolveReferences(Schema)

AsyncSerde<TParsedSchema>.IgnoreReference(string)

AsyncSerde<TParsedSchema>.GetMigrations(string, Schema, RegisteredSchema)

AsyncSerde<TParsedSchema>.GetReaderSchema(string, Schema)

AsyncSerde<TParsedSchema>.ExecuteMigrations(IList<Migration>, bool, string, string, Headers, object)

AsyncSerde<TParsedSchema>.ExecuteRules(bool, string, string, Headers, RuleMode, Schema, Schema, object, FieldTransformer)

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Namespace: Confluent.SchemaRegistry

Assembly: Confluent.SchemaRegistry.dll

Syntax

public abstract class AsyncSerializer<T, TParsedSchema> : AsyncSerde<TParsedSchema>, IAsyncSerializer<T>

Type Parameters

Name	Description
T
TParsedSchema

Constructors

AsyncSerializer(ISchemaRegistryClient, SerdeConfig, RuleRegistry)

Declaration

protected AsyncSerializer(ISchemaRegistryClient schemaRegistryClient, SerdeConfig config, RuleRegistry ruleRegistry = null)

Parameters

Type	Name	Description
ISchemaRegistryClient	schemaRegistryClient
SerdeConfig	config
RuleRegistry	ruleRegistry

Fields

autoRegisterSchema

Declaration

protected bool autoRegisterSchema

Field Value

Type	Description
bool

initialBufferSize

Declaration

protected int initialBufferSize

Field Value

Type	Description
int

normalizeSchemas

Declaration

protected bool normalizeSchemas

Field Value

Type	Description
bool

schemaIdEncoder

Declaration

protected ISchemaIdEncoder schemaIdEncoder

Field Value

Type	Description
ISchemaIdEncoder

subjectsRegistered

Declaration

protected HashSet<string> subjectsRegistered

Field Value

Type	Description
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

Type	Name	Description
T	value
SerializationContext	context	Context relevant to the serialize operation.

Returns

Type	Description
Task<byte[]>	A Task that completes with the serialized data.

Implements

IAsyncSerializer<T>