Class AvroMessageSerializerBuilder

Namespace

Silverback.Messaging.Configuration

Assembly

Silverback.Integration.Kafka.SchemaRegistry.dll

Builds the AvroMessageSerializer<TMessage>.

public class AvroMessageSerializerBuilder : SchemaRegistrySerializerBuilder<AvroMessageSerializerBuilder>

Inheritance

object

SchemaRegistrySerializerBuilder<AvroMessageSerializerBuilder>

AvroMessageSerializerBuilder

Inherited Members

SchemaRegistrySerializerBuilder<AvroMessageSerializerBuilder>.UseModel<TMessage>()

SchemaRegistrySerializerBuilder<AvroMessageSerializerBuilder>.UseModel(Type)

SchemaRegistrySerializerBuilder<AvroMessageSerializerBuilder>.ConnectToSchemaRegistry(Action<KafkaSchemaRegistryConfigurationBuilder>)

SchemaRegistrySerializerBuilder<AvroMessageSerializerBuilder>.ConnectToSchemaRegistry(string, Action<KafkaSchemaRegistryConfigurationBuilder>)

SchemaRegistrySerializerBuilder<AvroMessageSerializerBuilder>.Build()

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Constructors

AvroMessageSerializerBuilder(IConfluentSchemaRegistryClientFactory)

Initializes a new instance of the AvroMessageSerializerBuilder class.

public AvroMessageSerializerBuilder(IConfluentSchemaRegistryClientFactory schemaRegistryClientFactory)

Parameters

schemaRegistryClientFactory IConfluentSchemaRegistryClientFactory

The IConfluentSchemaRegistryClientFactory to be used to create the schema registry client.

Properties

This

Gets the actual builder instance.

protected override AvroMessageSerializerBuilder This { get; }

Property Value

AvroMessageSerializerBuilder

Methods

BuildCore(Type, ISchemaRegistryClient)

Builds the IMessageSerializer instance.

protected override IMessageSerializer BuildCore(Type messageType, ISchemaRegistryClient schemaRegistryClient)

Parameters

messageType Type

The type of the message to serialize.

schemaRegistryClient ISchemaRegistryClient

The schema registry client.

Returns

IMessageSerializer

The IMessageSerializer.

Configure(Action<AvroSerializerConfig>)

Configures the Confluent.SchemaRegistry.Serdes.AvroSerializerConfig.

public AvroMessageSerializerBuilder Configure(Action<AvroSerializerConfig> configureAction)

Parameters

configureAction Action<AvroSerializerConfig>

An Action<T> that takes the Confluent.SchemaRegistry.Serdes.AvroSerializerConfig and configures it.

Returns

AvroMessageSerializerBuilder

The AvroMessageSerializerBuilder so that additional calls can be chained.