Class KafkaProducerEndpointNameResolver<TMessage>

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

Inheritance
object
ProducerEndpointNameResolver<TMessage>
KafkaProducerEndpointNameResolver<TMessage>
Inherited Members
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)

Gets the target partition for the message being produced.

Declaration
public int? GetPartition(IOutboundEnvelope envelope)
Parameters
Type Name Description
IOutboundEnvelope envelope

The envelope containing the message being produced.
Returns
Type Description
int?

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).
| 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
int?

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