Method AddSchemaRegistryAvroSharpSerializer

Namespace

AvroSharp.KafkaFlow

Assembly

AvroSharp.KafkaFlow.dll

AddSchemaRegistryAvroSharpSerializer(IProducerMiddlewareConfigurationBuilder, AvroSharpSerializerConfig?)

Writes each produced message with AvroSharpKafkaFlowSerializer: of any type AvroTypes knows.

public static IProducerMiddlewareConfigurationBuilder AddSchemaRegistryAvroSharpSerializer(this IProducerMiddlewareConfigurationBuilder middlewares, AvroSharpSerializerConfig? config = null)

Parameters

middlewares IProducerMiddlewareConfigurationBuilder

The producer's middlewares.

config AvroSharpSerializerConfig

The settings, or null for the defaults. The schema ID can't go in a header.

Returns

IProducerMiddlewareConfigurationBuilder

Exceptions

ArgumentException

config puts the schema ID in a header, or enables both use.latest.version and auto.register.schemas.