Class KafkaStaticProducerEndpointResolver
Statically resolves to the same target topic and partition (if specified) for every message being produced.
Inheritance
KafkaStaticProducerEndpointResolver
Implements
Inherited Members
Namespace: Silverback.Messaging.Producing.EndpointResolvers
Assembly: Silverback.Integration.Kafka.dll
Syntax
public sealed class KafkaStaticProducerEndpointResolver : StaticProducerEndpointResolver<KafkaProducerEndpoint, KafkaProducerEndpointConfiguration>, IStaticProducerEndpointResolver<KafkaProducerEndpoint>, IStaticProducerEndpointResolver, IProducerEndpointResolver<KafkaProducerEndpoint>, IProducerEndpointResolver, IEquatable<StaticProducerEndpointResolver<KafkaProducerEndpoint, KafkaProducerEndpointConfiguration>>Constructors
KafkaStaticProducerEndpointResolver(TopicPartition)
Initializes a new instance of the KafkaStaticProducerEndpointResolver class.
Declaration
public KafkaStaticProducerEndpointResolver(TopicPartition topicPartition)Parameters
| Type | Name | Description |
|---|---|---|
| TopicPartition | topicPartition | The target topic and partition. |
KafkaStaticProducerEndpointResolver(string, int?)
Initializes a new instance of the KafkaStaticProducerEndpointResolver class.
Declaration
public KafkaStaticProducerEndpointResolver(string topic, int? partition = null)Parameters
| Type | Name | Description |
|---|---|---|
| string | topic | The target topic. |
| int? | partition | The optional target partition index. |
Properties
TopicPartition
Gets the target topic and partition.
Declaration
public TopicPartition TopicPartition { get; }Property Value
| Type | Description |
|---|---|
| TopicPartition |
Methods
GetEndpointCore(KafkaProducerEndpointConfiguration)
Gets the static destination endpoint.
Declaration
protected override KafkaProducerEndpoint GetEndpointCore(KafkaProducerEndpointConfiguration configuration)Parameters
| Type | Name | Description |
|---|---|---|
| KafkaProducerEndpointConfiguration | configuration | The producer endpoint configuration. |
Returns
| Type | Description |
|---|---|
| KafkaProducerEndpoint | The ProducerEndpoint. |
Overrides
Remarks
This method will be called once and the result will be cached.