Class KafkaMessageKeyInitializerProducerBehavior

Sets the message key header with the value from the properties decorated with the KafkaKeyMemberAttribute. The header will be used by the KafkaProducer to set the actual message key.

Inheritance
System.Object
KafkaMessageKeyInitializerProducerBehavior
Inherited Members
System.Object.Equals(System.Object)
System.Object.Equals(System.Object, System.Object)
System.Object.GetHashCode()
System.Object.GetType()
System.Object.MemberwiseClone()
System.Object.ReferenceEquals(System.Object, System.Object)
System.Object.ToString()
Namespace: Silverback.Messaging.Outbound
Assembly: Silverback.Integration.Kafka.dll
Syntax
public class KafkaMessageKeyInitializerProducerBehavior : IProducerBehavior, IBrokerBehavior, ISorted

Properties

| Improve this doc View source

SortIndex

Declaration
public int SortIndex { get; }
Property Value
Type Description
System.Int32

Methods

| Improve this doc View source

HandleAsync(ProducerPipelineContext, ProducerBehaviorHandler)

Declaration
public async Task HandleAsync(ProducerPipelineContext context, ProducerBehaviorHandler next)
Parameters
Type Name Description
ProducerPipelineContext context
ProducerBehaviorHandler next
Returns
Type Description
System.Threading.Tasks.Task

Implements