Interface IKafkaProducerEndpointNameResolver

Represents a type used to resolve the actual target endpoint name for the outbound message.

Inherited Members

IProducerEndpointNameResolver.GetName(IOutboundEnvelope)

Namespace: Silverback.Messaging.Outbound.Routing

Assembly: Silverback.Integration.Kafka.dll

Syntax

public interface IKafkaProducerEndpointNameResolver : IProducerEndpointNameResolver

Methods

GetPartition(IOutboundEnvelope)

Gets the target partition for the message being produced.

Declaration

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