Class JsonSchemaRegistryMessageDeserializerBuilder

Builds the JsonSchemaRegistryMessageDeserializer<TMessage>.

Inheritance

object

SchemaRegistryDeserializerBuilder<JsonSchemaRegistryMessageDeserializerBuilder>

JsonSchemaRegistryMessageDeserializerBuilder

Inherited Members

SchemaRegistryDeserializerBuilder<JsonSchemaRegistryMessageDeserializerBuilder>.UseModel<TMessage>()

SchemaRegistryDeserializerBuilder<JsonSchemaRegistryMessageDeserializerBuilder>.UseModel(Type)

SchemaRegistryDeserializerBuilder<JsonSchemaRegistryMessageDeserializerBuilder>.ConnectToSchemaRegistry(Action<KafkaSchemaRegistryConfigurationBuilder>)

SchemaRegistryDeserializerBuilder<JsonSchemaRegistryMessageDeserializerBuilder>.ConnectToSchemaRegistry(string, Action<KafkaSchemaRegistryConfigurationBuilder>)

SchemaRegistryDeserializerBuilder<JsonSchemaRegistryMessageDeserializerBuilder>.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 JsonSchemaRegistryMessageDeserializerBuilder : SchemaRegistryDeserializerBuilder<JsonSchemaRegistryMessageDeserializerBuilder>

Constructors

JsonSchemaRegistryMessageDeserializerBuilder(IConfluentSchemaRegistryClientFactory)

Initializes a new instance of the JsonSchemaRegistryMessageDeserializerBuilder class.

Declaration

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

Property Value

Type	Description
JsonSchemaRegistryMessageDeserializerBuilder

Overrides

SchemaRegistryDeserializerBuilder<JsonSchemaRegistryMessageDeserializerBuilder>.This

Methods

BuildCore(Type, ISchemaRegistryClient)

Builds the IMessageDeserializer instance.

Declaration

protected override IMessageDeserializer 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
IMessageDeserializer	The IMessageDeserializer.

Overrides

SchemaRegistryDeserializerBuilder<JsonSchemaRegistryMessageDeserializerBuilder>.BuildCore(Type, ISchemaRegistryClient)

Configure(Action<JsonDeserializerConfig>)

Configures the Confluent.SchemaRegistry.Serdes.JsonDeserializerConfig.

Declaration

public JsonSchemaRegistryMessageDeserializerBuilder Configure(Action<JsonDeserializerConfig> configureAction)

Parameters

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

Returns

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

ConfigureSchemaGenerator(Action<JsonSchemaGeneratorSettings>)

Configures the NJsonSchema.Generation.JsonSchemaGeneratorSettings.

Declaration

public JsonSchemaRegistryMessageDeserializerBuilder 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
JsonSchemaRegistryMessageDeserializerBuilder	The JsonSchemaRegistryMessageDeserializerBuilder so that additional calls can be chained.