DlqNoopPipelineStep

constructor(numWorkers: Int, taskFactory: LoadPipelineStepTaskFactory, dlqInputQueue: PartitionedQueue<PipelineEvent<StreamKey, DestinationRecordRaw>>)