Class JsonSchemaRegistryMessageSerializerBuilder

Namespace

Silverback.Messaging.Configuration

Assembly

Silverback.Integration.Kafka.SchemaRegistry.dll

Builds the JsonSchemaRegistryMessageSerializer<TMessage>.

public class JsonSchemaRegistryMessageSerializerBuilder : SchemaRegistrySerializerBuilder<JsonSchemaRegistryMessageSerializerBuilder>

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()

Constructors

JsonSchemaRegistryMessageSerializerBuilder(IConfluentSchemaRegistryClientFactory)

Initializes a new instance of the JsonSchemaRegistryMessageSerializerBuilder class.

public JsonSchemaRegistryMessageSerializerBuilder(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 JsonSchemaRegistryMessageSerializerBuilder This { get; }

Property Value

JsonSchemaRegistryMessageSerializerBuilder

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<JsonSerializerConfig>)

Configures the Confluent.SchemaRegistry.Serdes.JsonSerializerConfig.

public JsonSchemaRegistryMessageSerializerBuilder Configure(Action<JsonSerializerConfig> configureAction)

Parameters

configureAction Action<JsonSerializerConfig>

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

Returns

JsonSchemaRegistryMessageSerializerBuilder

The JsonSchemaRegistryMessageSerializerBuilder so that additional calls can be chained.

ConfigureSchemaGenerator(Action<JsonSchemaGeneratorSettings>)

Configures the NJsonSchema.Generation.JsonSchemaGeneratorSettings.

public JsonSchemaRegistryMessageSerializerBuilder ConfigureSchemaGenerator(Action<JsonSchemaGeneratorSettings> configureAction)

Parameters

configureAction Action<JsonSchemaGeneratorSettings>

An Action<T> that takes the NJsonSchema.Generation.JsonSchemaGeneratorSettings and configures it.

Returns

JsonSchemaRegistryMessageSerializerBuilder

The JsonSchemaRegistryMessageSerializerBuilder so that additional calls can be chained.