Class AsyncSerde<TParsedSchema>

public abstract class AsyncSerde<TParsedSchema>

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

protected bool latestCompatibilityStrict

protected RuleRegistry ruleRegistry

protected ISchemaRegistryClient schemaRegistryClient

protected SemaphoreSlim serdeMutex

protected SubjectNameStrategyDelegate subjectNameStrategy

protected bool useLatestVersion

protected IDictionary<string, string> useLatestWithMetadata

protected int useSchemaId

protected Task<object> ExecuteMigrations(IList<Migration> migrations, bool isKey, string subject, string topic, Headers headers, object message)

protected Task<object> ExecuteRules(bool isKey, string subject, string topic, Headers headers, RuleMode ruleMode, Schema source, Schema target, object message, FieldTransformer fieldTransformer)

protected Task<object> ExecuteRules(bool isKey, string subject, string topic, Headers headers, RulePhase rulePhase, RuleMode ruleMode, Schema source, Schema target, object message, FieldTransformer fieldTransformer)

protected Task<IList<Migration>> GetMigrations(string subject, Schema writer, RegisteredSchema readerSchema)

protected Task<TParsedSchema> GetParsedSchema(Schema schema)

protected Task<RegisteredSchema> GetReaderSchema(string subject, Schema schema = null)

protected string GetSubjectName(string topic, bool isKey, string recordType)

protected Task<(Schema, TParsedSchema)> GetWriterSchema(string subject, SchemaId writerId, string format = null)

protected virtual bool IgnoreReference(string name)

protected abstract Task<TParsedSchema> ParseSchema(Schema schema)

protected Task<IDictionary<string, string>> ResolveReferences(Schema schema)