bulk-cdk-toolkit-load-dlq/io.airbyte.cdk.load.write.dlq

Package-level declarations

Types

Link copied to clipboard
interface DlqLoader<S> : AutoCloseable

DeadLetterQueueLoader interface.

Link copied to clipboard
class DlqPipelineFactory(dlqInputQueue: PartitionedQueue<PipelineEvent<StreamKey, DestinationRecordRaw>>, dlqPipelineSteps: List<LoadPipelineStep>, pipelineStepTaskFactory: LoadPipelineStepTaskFactory, objectLoader: ObjectLoader)

Factory to build a DeadLetterQueueLoadPipeline.

Link copied to clipboard
@Factory
class DlqPipelineFactoryFactory

A Micronaut Factory to help initialize the component required for a DeadLetterQueuePipeline