DlqLoaderPipelineStep
class DlqLoaderPipelineStep<S : AutoCloseable>(val numWorkers: Int, taskFactory: LoadPipelineStepTaskFactory, dlqLoader: DlqLoader<S>, outputQueue: PartitionedQueue<PipelineEvent<StreamKey, DestinationRecordRaw>>) : LoadPipelineStep
DeadLetterQueue Loader Pipeline Step.
This is the first step of the dead letter queue pipeline that will wrap the destination implementer code.
Constructors
Link copied to clipboard
constructor(numWorkers: Int, taskFactory: LoadPipelineStepTaskFactory, dlqLoader: DlqLoader<S>, outputQueue: PartitionedQueue<PipelineEvent<StreamKey, DestinationRecordRaw>>)