Class ConsumerEndpointConfigurationBuilderSchemaRegistryExtensions

Adds the DeserializeAvro<TMessage, TConfiguration, TBuilder>(ConsumerEndpointConfigurationBuilder<TMessage, TConfiguration, TBuilder>, Action<AvroMessageDeserializerBuilder>?), DeserializeJsonUsingSchemaRegistry<TMessage, TConfiguration, TBuilder>(ConsumerEndpointConfigurationBuilder<TMessage, TConfiguration, TBuilder>, Action<JsonSchemaRegistryMessageDeserializerBuilder>?) and DeserializeProtobuf<TMessage, TConfiguration, TBuilder>(ConsumerEndpointConfigurationBuilder<TMessage, TConfiguration, TBuilder>, Action<ProtobufMessageDeserializerBuilder>?) methods to the ConsumerEndpointConfigurationBuilder<TMessage, TConfiguration, TBuilder>.

Inheritance

object

ConsumerEndpointConfigurationBuilderSchemaRegistryExtensions

Inherited Members

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 static class ConsumerEndpointConfigurationBuilderSchemaRegistryExtensions

Methods

DeserializeAvro<TMessage, TConfiguration, TBuilder>(ConsumerEndpointConfigurationBuilder<TMessage, TConfiguration, TBuilder>, Action<AvroMessageDeserializerBuilder>?)

Sets the deserializer to an instance of AvroMessageDeserializer<TMessage> to deserialize the consumed Avro serialized message.

Declaration

public static TBuilder DeserializeAvro<TMessage, TConfiguration, TBuilder>(this ConsumerEndpointConfigurationBuilder<TMessage, TConfiguration, TBuilder> endpointBuilder, Action<AvroMessageDeserializerBuilder>? deserializerBuilderAction = null) where TMessage : class where TConfiguration : ConsumerEndpointConfiguration where TBuilder : ConsumerEndpointConfigurationBuilder<TMessage, TConfiguration, TBuilder>

Parameters

Type	Name	Description
ConsumerEndpointConfigurationBuilder<TMessage, TConfiguration, TBuilder>	endpointBuilder	The endpoint builder.
Action<AvroMessageDeserializerBuilder>	deserializerBuilderAction	An optional Action<T> that takes the AvroMessageDeserializerBuilder and configures it.

Returns

Type	Description
TBuilder	The endpoint builder so that additional calls can be chained.

Type Parameters

Name	Description
TMessage	The type of the messages being consumed.
TConfiguration	The type of the configuration being built.
TBuilder	The actual builder type.

DeserializeJsonUsingSchemaRegistry<TMessage, TConfiguration, TBuilder>(ConsumerEndpointConfigurationBuilder<TMessage, TConfiguration, TBuilder>, Action<JsonSchemaRegistryMessageDeserializerBuilder>?)

Sets the deserializer to an instance of JsonSchemaRegistryMessageDeserializer<TMessage> to deserialize the consumed JSON message using the schema registry.

Declaration

public static TBuilder DeserializeJsonUsingSchemaRegistry<TMessage, TConfiguration, TBuilder>(this ConsumerEndpointConfigurationBuilder<TMessage, TConfiguration, TBuilder> endpointBuilder, Action<JsonSchemaRegistryMessageDeserializerBuilder>? deserializerBuilderAction = null) where TMessage : class where TConfiguration : ConsumerEndpointConfiguration where TBuilder : ConsumerEndpointConfigurationBuilder<TMessage, TConfiguration, TBuilder>

Parameters

Type	Name	Description
ConsumerEndpointConfigurationBuilder<TMessage, TConfiguration, TBuilder>	endpointBuilder	The endpoint builder.
Action<JsonSchemaRegistryMessageDeserializerBuilder>	deserializerBuilderAction	An optional Action<T> that takes the JsonSchemaRegistryMessageDeserializerBuilder and configures it.

Returns

Type	Description
TBuilder	The endpoint builder so that additional calls can be chained.

Type Parameters

Name	Description
TMessage	The type of the messages being consumed.
TConfiguration	The type of the configuration being built.
TBuilder	The actual builder type.

DeserializeProtobuf<TMessage, TConfiguration, TBuilder>(ConsumerEndpointConfigurationBuilder<TMessage, TConfiguration, TBuilder>, Action<ProtobufMessageDeserializerBuilder>?)

Sets the deserializer to an instance of ProtobufMessageDeserializer<TMessage> to deserialize the consumed Protobuf serialized message.

Declaration

public static TBuilder DeserializeProtobuf<TMessage, TConfiguration, TBuilder>(this ConsumerEndpointConfigurationBuilder<TMessage, TConfiguration, TBuilder> endpointBuilder, Action<ProtobufMessageDeserializerBuilder>? deserializerBuilderAction = null) where TMessage : class, IMessage<TMessage>, new() where TConfiguration : ConsumerEndpointConfiguration where TBuilder : ConsumerEndpointConfigurationBuilder<TMessage, TConfiguration, TBuilder>

Parameters

Type	Name	Description
ConsumerEndpointConfigurationBuilder<TMessage, TConfiguration, TBuilder>	endpointBuilder	The endpoint builder.
Action<ProtobufMessageDeserializerBuilder>	deserializerBuilderAction	An optional Action<T> that takes the ProtobufMessageDeserializerBuilder and configures it.

Returns

Type	Description
TBuilder	The endpoint builder so that additional calls can be chained.

Type Parameters

Name	Description
TMessage	The type of the messages being consumed.
TConfiguration	The type of the configuration being built.
TBuilder	The actual builder type.