Class KafkaDeadLetterDestination<T, TRecordKey, TRecordValue>

Namespace

Pipelinez.Kafka.Destination

Assembly

Pipelinez.Kafka.dll

Writes Pipelinez dead-letter records to a Kafka topic.

public sealed class KafkaDeadLetterDestination<T, TRecordKey, TRecordValue> : IPipelineDeadLetterDestination<T> where T : PipelineRecord where TRecordKey : class where TRecordValue : class

Type Parameters

T

The pipeline record type being dead-lettered.

TRecordKey

The Kafka message key type.

TRecordValue

The Kafka message value type.

Inheritance

object

KafkaDeadLetterDestination<T, TRecordKey, TRecordValue>

Implements

IPipelineDeadLetterDestination<T>

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

KafkaDeadLetterDestination(string, KafkaDestinationOptions, Func<PipelineDeadLetterRecord<T>, Message<TRecordKey, TRecordValue>>)

Initializes a new Kafka dead-letter destination for the specified pipeline.

public KafkaDeadLetterDestination(string pipelineName, KafkaDestinationOptions config, Func<PipelineDeadLetterRecord<T>, Message<TRecordKey, TRecordValue>> messageMapper)

Parameters

pipelineName string

The owning pipeline name.

config KafkaDestinationOptions

The Kafka destination configuration.

messageMapper Func<PipelineDeadLetterRecord<T>, Message<TRecordKey, TRecordValue>>

Maps a dead-letter record into the Kafka message to publish.

Methods

WriteAsync(PipelineDeadLetterRecord<T>, CancellationToken)

Writes a dead-letter record to the configured store.

public Task WriteAsync(PipelineDeadLetterRecord<T> deadLetterRecord, CancellationToken cancellationToken)

Parameters

deadLetterRecord PipelineDeadLetterRecord<T>

The dead-letter record to persist.

cancellationToken CancellationToken

A token used to cancel the write operation.

Returns

Task