Class KafkaProducerEndpointNameResolver<TMessage>

The base class for a type used to resolve the actual target endpoint name for the outbound message.

Inheritance
System.Object
ProducerEndpointNameResolver<TMessage>
KafkaProducerEndpointNameResolver<TMessage>
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 abstract class KafkaProducerEndpointNameResolver<TMessage> : ProducerEndpointNameResolver<TMessage>, IKafkaProducerEndpointNameResolver, IProducerEndpointNameResolver where TMessage : class
Type Parameters
Name Description
TMessage

The type of the messages being produced.

Methods

| Improve this doc View source

GetPartition(IOutboundEnvelope)

Declaration
public int? GetPartition(IOutboundEnvelope envelope)
Parameters
Type Name Description
IOutboundEnvelope envelope
Returns
Type Description
System.Nullable<System.Int32>
| Improve this doc View source

GetPartition(IOutboundEnvelope<TMessage>)

Gets the target partition for the message being produced.

Declaration
protected abstract int? GetPartition(IOutboundEnvelope<TMessage> envelope)
Parameters
Type Name Description
IOutboundEnvelope<TMessage> envelope

The envelope containing the message being produced.
Returns
Type Description
System.Nullable<System.Int32>

The target partition index. If null the partition is automatically derived from the message key (use KafkaKeyMemberAttribute to specify a message key, otherwise a random one will be generated).

Implements