Constructor AvroSharpMessageTypeResolver

Namespace

AvroSharp.KafkaFlow

Assembly

AvroSharp.KafkaFlow.dll

AvroSharpMessageTypeResolver(ISchemaRegistryClient, IEnumerable<Type>)

Creates a resolver that picks among messageTypes, by their records' full names and aliases.

public AvroSharpMessageTypeResolver(ISchemaRegistryClient client, IEnumerable<Type> messageTypes)

Parameters

client ISchemaRegistryClient

The schema registry.

messageTypes IEnumerable<Type>

The types messages are read as: types AvroTypes knows, of record schemas.

Exceptions

ArgumentException

No types are given, a type's schema isn't a record, or two types have records of the same name or alias.

InvalidOperationException

A type is not one AvroTypes knows.

AvroSharpMessageTypeResolver(ISchemaRegistryClient)

Creates a resolver that finds the type of a record's full name in the loaded assemblies, as KafkaFlow's Confluent Avro deserializer does.

[RequiresUnreferencedCode("The message types are found by name in the loaded assemblies, and trimming can remove them. Pass the message types to the other constructor instead.")]
public AvroSharpMessageTypeResolver(ISchemaRegistryClient client)

Parameters

client ISchemaRegistryClient

The schema registry.