Class KafkaStaticProducerEndpointResolver

Namespace

Silverback.Messaging.Producing.EndpointResolvers

Assembly

Silverback.Integration.Kafka.dll

Statically resolves to the same target topic and partition (if specified) for every message being produced.

public sealed class KafkaStaticProducerEndpointResolver : StaticProducerEndpointResolver<KafkaProducerEndpoint, KafkaProducerEndpointConfiguration>, IStaticProducerEndpointResolver<KafkaProducerEndpoint>, IStaticProducerEndpointResolver, IProducerEndpointResolver<KafkaProducerEndpoint>, IProducerEndpointResolver, IEquatable<StaticProducerEndpointResolver<KafkaProducerEndpoint, KafkaProducerEndpointConfiguration>>

Inheritance

object

StaticProducerEndpointResolver<KafkaProducerEndpoint, KafkaProducerEndpointConfiguration>

KafkaStaticProducerEndpointResolver

Implements

IStaticProducerEndpointResolver<KafkaProducerEndpoint>

IStaticProducerEndpointResolver

IProducerEndpointResolver<KafkaProducerEndpoint>

IProducerEndpointResolver

IEquatable<StaticProducerEndpointResolver<KafkaProducerEndpoint, KafkaProducerEndpointConfiguration>>

Inherited Members

StaticProducerEndpointResolver<KafkaProducerEndpoint, KafkaProducerEndpointConfiguration>.GetEndpoint(ProducerEndpointConfiguration)

StaticProducerEndpointResolver<KafkaProducerEndpoint, KafkaProducerEndpointConfiguration>.GetEndpoint(IOutboundEnvelope)

StaticProducerEndpointResolver<KafkaProducerEndpoint, KafkaProducerEndpointConfiguration>.GetEndpoint(KafkaProducerEndpointConfiguration)

StaticProducerEndpointResolver<KafkaProducerEndpoint, KafkaProducerEndpointConfiguration>.Equals(StaticProducerEndpointResolver<KafkaProducerEndpoint, KafkaProducerEndpointConfiguration>)

StaticProducerEndpointResolver<KafkaProducerEndpoint, KafkaProducerEndpointConfiguration>.Equals(object)

StaticProducerEndpointResolver<KafkaProducerEndpoint, KafkaProducerEndpointConfiguration>.GetHashCode()

StaticProducerEndpointResolver<KafkaProducerEndpoint, KafkaProducerEndpointConfiguration>.RawName

object.GetType()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Constructors

KafkaStaticProducerEndpointResolver(TopicPartition)

Initializes a new instance of the KafkaStaticProducerEndpointResolver class.

public KafkaStaticProducerEndpointResolver(TopicPartition topicPartition)

Parameters

topicPartition TopicPartition

The target topic and partition.

KafkaStaticProducerEndpointResolver(string, int?)

Initializes a new instance of the KafkaStaticProducerEndpointResolver class.

public KafkaStaticProducerEndpointResolver(string topic, int? partition = null)

Parameters

topic string

The target topic.

partition int?

The optional target partition index.

Properties

TopicPartition

Gets the target topic and partition.

public TopicPartition TopicPartition { get; }

Property Value

TopicPartition

Methods

GetEndpointCore(KafkaProducerEndpointConfiguration)

Gets the static destination endpoint.

protected override KafkaProducerEndpoint GetEndpointCore(KafkaProducerEndpointConfiguration configuration)

Parameters

configuration KafkaProducerEndpointConfiguration

The producer endpoint configuration.

Returns

KafkaProducerEndpoint

The ProducerEndpoint.

Remarks

This method will be called once and the result will be cached.