Class KafkaPartitionResolverProducerBehavior
Resolves the target partition for the message being published using the GetPartition(IOutboundEnvelope, IServiceProvider) method.
Inheritance
System.Object
KafkaPartitionResolverProducerBehavior
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.Routing
Assembly: Silverback.Integration.Kafka.dll
Syntax
public class KafkaPartitionResolverProducerBehavior : IProducerBehavior, IBrokerBehavior, ISortedProperties
| Improve this doc View sourceSortIndex
Declaration
public int SortIndex { get; }Property Value
| Type | Description |
|---|---|
| System.Int32 |
Methods
| Improve this doc View sourceHandleAsync(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 |