Interface IKafkaProducerEndpointResolver<TMessage>

Namespace

Silverback.Messaging.Producing.EndpointResolvers

Assembly

Silverback.Integration.Kafka.dll

A type used to resolve the target topic and partition for the outbound message.

public interface IKafkaProducerEndpointResolver<in TMessage>

Type Parameters

TMessage

The type of the messages being produced.

Methods

GetTopicPartition(IOutboundEnvelope<TMessage>)

Gets the target topic and partition for the message being produced.

TopicPartition GetTopicPartition(IOutboundEnvelope<in TMessage> envelope)

Parameters

envelope IOutboundEnvelope<TMessage>

The envelope containing the message to be produced.

Returns

TopicPartition

The target Confluent.Kafka.TopicPartition.