Class JsonSchemaRegistryMessageDeserializerBuilder

Namespace

Silverback.Messaging.Configuration

Assembly

Silverback.Integration.Kafka.SchemaRegistry.dll

Builds the JsonSchemaRegistryMessageDeserializer<TMessage>.

public class JsonSchemaRegistryMessageDeserializerBuilder : SchemaRegistryDeserializerBuilder<JsonSchemaRegistryMessageDeserializerBuilder>

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

Constructors

JsonSchemaRegistryMessageDeserializerBuilder(IConfluentSchemaRegistryClientFactory)

Initializes a new instance of the JsonSchemaRegistryMessageDeserializerBuilder class.

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

Property Value

JsonSchemaRegistryMessageDeserializerBuilder

Methods

BuildCore(Type, ISchemaRegistryClient)

Builds the IMessageDeserializer instance.

protected override IMessageDeserializer BuildCore(Type messageType, ISchemaRegistryClient schemaRegistryClient)

Parameters

messageType Type

The type of the message to serialize.

schemaRegistryClient ISchemaRegistryClient

The schema registry client.

Returns

IMessageDeserializer

The IMessageDeserializer.

Configure(Action<JsonDeserializerConfig>)

Configures the Confluent.SchemaRegistry.Serdes.JsonDeserializerConfig.

public JsonSchemaRegistryMessageDeserializerBuilder Configure(Action<JsonDeserializerConfig> configureAction)

Parameters

configureAction Action<JsonDeserializerConfig>

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

Returns

JsonSchemaRegistryMessageDeserializerBuilder

The JsonSchemaRegistryMessageDeserializerBuilder so that additional calls can be chained.

ConfigureSchemaGenerator(Action<JsonSchemaGeneratorSettings>)

Configures the NJsonSchema.Generation.JsonSchemaGeneratorSettings.

public JsonSchemaRegistryMessageDeserializerBuilder ConfigureSchemaGenerator(Action<JsonSchemaGeneratorSettings> configureAction)

Parameters

configureAction Action<JsonSchemaGeneratorSettings>

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

Returns

JsonSchemaRegistryMessageDeserializerBuilder

The JsonSchemaRegistryMessageDeserializerBuilder so that additional calls can be chained.