Class JsonSchemaRegistryMessageSerializerBuilder

Builds the JsonSchemaRegistryMessageSerializer<TMessage>.

Inheritance

object

SchemaRegistrySerializerBuilder<JsonSchemaRegistryMessageSerializerBuilder>

JsonSchemaRegistryMessageSerializerBuilder

Inherited Members

SchemaRegistrySerializerBuilder<JsonSchemaRegistryMessageSerializerBuilder>.UseModel<TMessage>()

SchemaRegistrySerializerBuilder<JsonSchemaRegistryMessageSerializerBuilder>.UseModel(Type)

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

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

SchemaRegistrySerializerBuilder<JsonSchemaRegistryMessageSerializerBuilder>.Build()

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Namespace: Silverback.Messaging.Configuration

Assembly: Silverback.Integration.Kafka.SchemaRegistry.dll

Syntax

public class JsonSchemaRegistryMessageSerializerBuilder : SchemaRegistrySerializerBuilder<JsonSchemaRegistryMessageSerializerBuilder>

Constructors

JsonSchemaRegistryMessageSerializerBuilder(IConfluentSchemaRegistryClientFactory)

Initializes a new instance of the JsonSchemaRegistryMessageSerializerBuilder class.

Declaration

public JsonSchemaRegistryMessageSerializerBuilder(IConfluentSchemaRegistryClientFactory schemaRegistryClientFactory)

Parameters

Type	Name	Description
IConfluentSchemaRegistryClientFactory	schemaRegistryClientFactory	The IConfluentSchemaRegistryClientFactory to be used to create the schema registry client.

Properties

This

Gets the actual builder instance.

Declaration

protected override JsonSchemaRegistryMessageSerializerBuilder This { get; }

Property Value

Type	Description
JsonSchemaRegistryMessageSerializerBuilder

Overrides

SchemaRegistrySerializerBuilder<JsonSchemaRegistryMessageSerializerBuilder>.This

Methods

BuildCore(Type, ISchemaRegistryClient)

Builds the IMessageSerializer instance.

Declaration

protected override IMessageSerializer BuildCore(Type messageType, ISchemaRegistryClient schemaRegistryClient)

Parameters

Type	Name	Description
Type	messageType	The type of the message to serialize.
ISchemaRegistryClient	schemaRegistryClient	The schema registry client.

Returns

Type	Description
IMessageSerializer	The IMessageSerializer.

Overrides

SchemaRegistrySerializerBuilder<JsonSchemaRegistryMessageSerializerBuilder>.BuildCore(Type, ISchemaRegistryClient)

Configure(Action<JsonSerializerConfig>)

Configures the Confluent.SchemaRegistry.Serdes.JsonSerializerConfig.

Declaration

public JsonSchemaRegistryMessageSerializerBuilder Configure(Action<JsonSerializerConfig> configureAction)

Parameters

Type	Name	Description
Action<JsonSerializerConfig>	configureAction	An Action<T> that takes the Confluent.SchemaRegistry.Serdes.JsonSerializerConfig and configures it.

Returns

Type	Description
JsonSchemaRegistryMessageSerializerBuilder	The JsonSchemaRegistryMessageSerializerBuilder so that additional calls can be chained.

ConfigureSchemaGenerator(Action<JsonSchemaGeneratorSettings>)

Configures the NJsonSchema.Generation.JsonSchemaGeneratorSettings.

Declaration

public JsonSchemaRegistryMessageSerializerBuilder ConfigureSchemaGenerator(Action<JsonSchemaGeneratorSettings> configureAction)

Parameters

Type	Name	Description
Action<JsonSchemaGeneratorSettings>	configureAction	An Action<T> that takes the NJsonSchema.Generation.JsonSchemaGeneratorSettings and configures it.

Returns

Type	Description
JsonSchemaRegistryMessageSerializerBuilder	The JsonSchemaRegistryMessageSerializerBuilder so that additional calls can be chained.