Constructor AvroSharpKafkaFlowSerializer
AvroSharpKafkaFlowSerializer(ISchemaRegistryClient, AvroSharpSerializerConfig?)
Creates a serializer.
public AvroSharpKafkaFlowSerializer(ISchemaRegistryClient client, AvroSharpSerializerConfig? config = null)
Parameters
clientISchemaRegistryClientThe schema registry.
configAvroSharpSerializerConfigThe settings, or null for the defaults.
Exceptions
- ArgumentException
configputs the schema ID in a header (KafkaFlow's serializer middleware gives serializers no headers), or enables bothuse.latest.versionandauto.register.schemas(the default).