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