Class KafkaProducerEndpoint

Namespace

Silverback.Messaging

Assembly

Silverback.Integration.Kafka.dll

The Kafka topic and partition where the message must be produced to.

public record KafkaProducerEndpoint : ProducerEndpoint<KafkaProducerEndpointConfiguration>, IEquatable<Endpoint>, IEquatable<ProducerEndpoint>, IEquatable<ProducerEndpoint<KafkaProducerEndpointConfiguration>>, IEquatable<KafkaProducerEndpoint>

Inheritance

object

Endpoint

ProducerEndpoint

ProducerEndpoint<KafkaProducerEndpointConfiguration>

KafkaProducerEndpoint

Implements

IEquatable<Endpoint>

IEquatable<ProducerEndpoint>

IEquatable<ProducerEndpoint<KafkaProducerEndpointConfiguration>>

IEquatable<KafkaProducerEndpoint>

Inherited Members

ProducerEndpoint<KafkaProducerEndpointConfiguration>.Equals(ProducerEndpoint)

ProducerEndpoint<KafkaProducerEndpointConfiguration>.Configuration

ProducerEndpoint.Equals(Endpoint)

Endpoint.RawName

Endpoint.DisplayName

object.GetType()

object.MemberwiseClone()

object.Equals(object, object)

object.ReferenceEquals(object, object)

Constructors

KafkaProducerEndpoint(TopicPartition, KafkaProducerEndpointConfiguration)

Initializes a new instance of the KafkaProducerEndpoint class.

public KafkaProducerEndpoint(TopicPartition topicPartition, KafkaProducerEndpointConfiguration configuration)

Parameters

topicPartition TopicPartition

The topic and partition.

configuration KafkaProducerEndpointConfiguration

The producer configuration.

KafkaProducerEndpoint(KafkaProducerEndpoint)

protected KafkaProducerEndpoint(KafkaProducerEndpoint original)

Parameters

original KafkaProducerEndpoint

KafkaProducerEndpoint(string, Partition, KafkaProducerEndpointConfiguration)

Initializes a new instance of the KafkaProducerEndpoint class.

public KafkaProducerEndpoint(string topic, Partition partition, KafkaProducerEndpointConfiguration configuration)

Parameters

topic string

The topic.

partition Partition

The partition index.

configuration KafkaProducerEndpointConfiguration

The producer configuration.

Properties

EqualityContract

protected override Type EqualityContract { get; }

Property Value

Type

TopicPartition

Gets the target topic and partition.

public TopicPartition TopicPartition { get; }

Property Value

TopicPartition

Methods

Equals(KafkaProducerEndpoint?)

public virtual bool Equals(KafkaProducerEndpoint? other)

Parameters

other KafkaProducerEndpoint

Returns

bool

Equals(ProducerEndpoint<KafkaProducerEndpointConfiguration>?)

public override sealed bool Equals(ProducerEndpoint<KafkaProducerEndpointConfiguration>? other)

Parameters

other ProducerEndpoint<KafkaProducerEndpointConfiguration>

Returns

bool

Equals(object?)

public override bool Equals(object? obj)

Parameters

obj object

Returns

bool

GetHashCode()

public override int GetHashCode()

Returns

int

PrintMembers(StringBuilder)

protected override bool PrintMembers(StringBuilder builder)

Parameters

builder StringBuilder

Returns

bool

ToString()

public override string ToString()

Returns

string

Operators

operator ==(KafkaProducerEndpoint?, KafkaProducerEndpoint?)

public static bool operator ==(KafkaProducerEndpoint? left, KafkaProducerEndpoint? right)

Parameters

left KafkaProducerEndpoint

right KafkaProducerEndpoint

Returns

bool

operator !=(KafkaProducerEndpoint?, KafkaProducerEndpoint?)

public static bool operator !=(KafkaProducerEndpoint? left, KafkaProducerEndpoint? right)

Parameters

left KafkaProducerEndpoint

right KafkaProducerEndpoint

Returns

bool