Class KafkaConsumerEndpoint

Namespace

Silverback.Messaging

Assembly

Silverback.Integration.Kafka.dll

The Kafka topic and partition from which the message was consumed.

public record KafkaConsumerEndpoint : ConsumerEndpoint<KafkaConsumerEndpointConfiguration>, IEquatable<Endpoint>, IEquatable<ConsumerEndpoint>, IEquatable<ConsumerEndpoint<KafkaConsumerEndpointConfiguration>>, IEquatable<KafkaConsumerEndpoint>

Inheritance

object

Endpoint

ConsumerEndpoint

ConsumerEndpoint<KafkaConsumerEndpointConfiguration>

KafkaConsumerEndpoint

Implements

IEquatable<Endpoint>

IEquatable<ConsumerEndpoint>

IEquatable<ConsumerEndpoint<KafkaConsumerEndpointConfiguration>>

IEquatable<KafkaConsumerEndpoint>

Inherited Members

ConsumerEndpoint<KafkaConsumerEndpointConfiguration>.Equals(ConsumerEndpoint)

ConsumerEndpoint<KafkaConsumerEndpointConfiguration>.Configuration

ConsumerEndpoint.Equals(Endpoint)

Endpoint.RawName

Endpoint.DisplayName

object.GetType()

object.MemberwiseClone()

object.Equals(object, object)

object.ReferenceEquals(object, object)

Constructors

KafkaConsumerEndpoint(TopicPartition, KafkaConsumerEndpointConfiguration)

Initializes a new instance of the KafkaConsumerEndpoint class.

public KafkaConsumerEndpoint(TopicPartition topicPartition, KafkaConsumerEndpointConfiguration configuration)

Parameters

topicPartition TopicPartition

The topic and partition.

configuration KafkaConsumerEndpointConfiguration

The consumer configuration.

KafkaConsumerEndpoint(KafkaConsumerEndpoint)

protected KafkaConsumerEndpoint(KafkaConsumerEndpoint original)

Parameters

original KafkaConsumerEndpoint

KafkaConsumerEndpoint(string, Partition, KafkaConsumerEndpointConfiguration)

Initializes a new instance of the KafkaConsumerEndpoint class.

public KafkaConsumerEndpoint(string topic, Partition partition, KafkaConsumerEndpointConfiguration configuration)

Parameters

topic string

The topic.

partition Partition

The partition index.

configuration KafkaConsumerEndpointConfiguration

The consumer configuration.

Properties

EqualityContract

protected override Type EqualityContract { get; }

Property Value

Type

TopicPartition

Gets the source topic and partition.

public TopicPartition TopicPartition { get; }

Property Value

TopicPartition

Methods

Equals(ConsumerEndpoint<KafkaConsumerEndpointConfiguration>?)

public override sealed bool Equals(ConsumerEndpoint<KafkaConsumerEndpointConfiguration>? other)

Parameters

other ConsumerEndpoint<KafkaConsumerEndpointConfiguration>

Returns

bool

Equals(KafkaConsumerEndpoint?)

public virtual bool Equals(KafkaConsumerEndpoint? other)

Parameters

other KafkaConsumerEndpoint

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 ==(KafkaConsumerEndpoint?, KafkaConsumerEndpoint?)

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

Parameters

left KafkaConsumerEndpoint

right KafkaConsumerEndpoint

Returns

bool

operator !=(KafkaConsumerEndpoint?, KafkaConsumerEndpoint?)

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

Parameters

left KafkaConsumerEndpoint

right KafkaConsumerEndpoint

Returns

bool