Interface IKafkaProducerEndpointResolver<TMessage>
A type used to resolve the target topic and partition for the outbound message.
Namespace: Silverback.Messaging.Producing.EndpointResolvers
Assembly: Silverback.Integration.Kafka.dll
Syntax
public interface IKafkaProducerEndpointResolver<in TMessage>Type Parameters
| Name | Description |
|---|---|
| TMessage | The type of the messages being produced. |
Methods
GetTopicPartition(IOutboundEnvelope<TMessage>)
Gets the target topic and partition for the message being produced.
Declaration
TopicPartition GetTopicPartition(IOutboundEnvelope<in TMessage> envelope)Parameters
| Type | Name | Description |
|---|---|---|
| IOutboundEnvelope<TMessage> | envelope | The envelope containing the message to be produced. |
Returns
| Type | Description |
|---|---|
| TopicPartition | The target Confluent.Kafka.TopicPartition. |