dlqInputQueue

@Named(value = "dlqInputQueue")
@Singleton
fun dlqInputQueue(@Named(value = "globalMemoryManager") globalMemoryManager: ReservationManager): PartitionedQueue<PipelineEvent<StreamKey, DestinationRecordRaw>>

This queue is the input queue of a "traditional" ObjectStorageLoadPipeline

Effectively, a DLQ LoadPipeline is a custom pipeline step that may pass down records meant for the DLQ. The DLQ LoadPipeline upload to ObjectStorage leverages the usual object storage pipeline steps with the exception of the input.

This Queue is the shim between the DlqLoaderStep and the ObjectStorage input.