Class KafkaConsumerEndpoint
The Kafka topic and partition from which the message was consumed.
Inheritance
Implements
Inherited Members
Namespace: Silverback.Messaging
Assembly: Silverback.Integration.Kafka.dll
Syntax
public record KafkaConsumerEndpoint : ConsumerEndpoint<KafkaConsumerEndpointConfiguration>, IEquatable<Endpoint>, IEquatable<ConsumerEndpoint>, IEquatable<ConsumerEndpoint<KafkaConsumerEndpointConfiguration>>, IEquatable<KafkaConsumerEndpoint>Constructors
KafkaConsumerEndpoint(TopicPartition, KafkaConsumerEndpointConfiguration)
Initializes a new instance of the KafkaConsumerEndpoint class.
Declaration
public KafkaConsumerEndpoint(TopicPartition topicPartition, KafkaConsumerEndpointConfiguration configuration)Parameters
| Type | Name | Description |
|---|---|---|
| TopicPartition | topicPartition | The topic and partition. |
| KafkaConsumerEndpointConfiguration | configuration | The consumer configuration. |
KafkaConsumerEndpoint(KafkaConsumerEndpoint)
The Kafka topic and partition from which the message was consumed.
Declaration
protected KafkaConsumerEndpoint(KafkaConsumerEndpoint original)Parameters
| Type | Name | Description |
|---|---|---|
| KafkaConsumerEndpoint | original |
KafkaConsumerEndpoint(string, Partition, KafkaConsumerEndpointConfiguration)
Initializes a new instance of the KafkaConsumerEndpoint class.
Declaration
public KafkaConsumerEndpoint(string topic, Partition partition, KafkaConsumerEndpointConfiguration configuration)Parameters
| Type | Name | Description |
|---|---|---|
| string | topic | The topic. |
| Partition | partition | The partition index. |
| KafkaConsumerEndpointConfiguration | configuration | The consumer configuration. |
Properties
EqualityContract
The Kafka topic and partition from which the message was consumed.
Declaration
protected override Type EqualityContract { get; }Property Value
| Type | Description |
|---|---|
| Type |
Overrides
TopicPartition
Gets the source topic and partition.
Declaration
public TopicPartition TopicPartition { get; }Property Value
| Type | Description |
|---|---|
| TopicPartition |
Methods
Equals(ConsumerEndpoint<KafkaConsumerEndpointConfiguration>?)
The Kafka topic and partition from which the message was consumed.
Declaration
public override sealed bool Equals(ConsumerEndpoint<KafkaConsumerEndpointConfiguration>? other)Parameters
| Type | Name | Description |
|---|---|---|
| ConsumerEndpoint<KafkaConsumerEndpointConfiguration> | other |
Returns
| Type | Description |
|---|---|
| bool |
Overrides
Equals(KafkaConsumerEndpoint?)
The Kafka topic and partition from which the message was consumed.
Declaration
public virtual bool Equals(KafkaConsumerEndpoint? other)Parameters
| Type | Name | Description |
|---|---|---|
| KafkaConsumerEndpoint | other |
Returns
| Type | Description |
|---|---|
| bool |
Equals(object?)
The Kafka topic and partition from which the message was consumed.
Declaration
public override bool Equals(object? obj)Parameters
| Type | Name | Description |
|---|---|---|
| object | obj |
Returns
| Type | Description |
|---|---|
| bool |
Overrides
GetHashCode()
The Kafka topic and partition from which the message was consumed.
Declaration
public override int GetHashCode()Returns
| Type | Description |
|---|---|
| int |
Overrides
PrintMembers(StringBuilder)
The Kafka topic and partition from which the message was consumed.
Declaration
protected override bool PrintMembers(StringBuilder builder)Parameters
| Type | Name | Description |
|---|---|---|
| StringBuilder | builder |
Returns
| Type | Description |
|---|---|
| bool |
Overrides
ToString()
The Kafka topic and partition from which the message was consumed.
Declaration
public override string ToString()Returns
| Type | Description |
|---|---|
| string |
Overrides
Operators
operator ==(KafkaConsumerEndpoint?, KafkaConsumerEndpoint?)
The Kafka topic and partition from which the message was consumed.
Declaration
public static bool operator ==(KafkaConsumerEndpoint? left, KafkaConsumerEndpoint? right)Parameters
| Type | Name | Description |
|---|---|---|
| KafkaConsumerEndpoint | left | |
| KafkaConsumerEndpoint | right |
Returns
| Type | Description |
|---|---|
| bool |
operator !=(KafkaConsumerEndpoint?, KafkaConsumerEndpoint?)
The Kafka topic and partition from which the message was consumed.
Declaration
public static bool operator !=(KafkaConsumerEndpoint? left, KafkaConsumerEndpoint? right)Parameters
| Type | Name | Description |
|---|---|---|
| KafkaConsumerEndpoint | left | |
| KafkaConsumerEndpoint | right |
Returns
| Type | Description |
|---|---|
| bool |