Class ConsumerEndpointConfigurationBuilderSchemaRegistryExtensions

Namespace

Silverback.Messaging.Configuration

Assembly

Silverback.Integration.Kafka.SchemaRegistry.dll

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>.

public static class ConsumerEndpointConfigurationBuilderSchemaRegistryExtensions

Inheritance

object

ConsumerEndpointConfigurationBuilderSchemaRegistryExtensions

Inherited Members

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

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.

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

endpointBuilder ConsumerEndpointConfigurationBuilder<TMessage, TConfiguration, TBuilder>

The endpoint builder.

deserializerBuilderAction Action<AvroMessageDeserializerBuilder>

An optional Action<T> that takes the AvroMessageDeserializerBuilder and configures it.

Returns

TBuilder

The endpoint builder so that additional calls can be chained.

Type Parameters

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.

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

endpointBuilder ConsumerEndpointConfigurationBuilder<TMessage, TConfiguration, TBuilder>

The endpoint builder.

deserializerBuilderAction Action<JsonSchemaRegistryMessageDeserializerBuilder>

An optional Action<T> that takes the JsonSchemaRegistryMessageDeserializerBuilder and configures it.

Returns

TBuilder

The endpoint builder so that additional calls can be chained.

Type Parameters

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.

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

endpointBuilder ConsumerEndpointConfigurationBuilder<TMessage, TConfiguration, TBuilder>

The endpoint builder.

deserializerBuilderAction Action<ProtobufMessageDeserializerBuilder>

An optional Action<T> that takes the ProtobufMessageDeserializerBuilder and configures it.

Returns

TBuilder

The endpoint builder so that additional calls can be chained.

Type Parameters

TMessage

The type of the messages being consumed.

TConfiguration

The type of the configuration being built.

TBuilder

The actual builder type.