FlattenQueueAdapter

Queue Adapter in order to be able to reuse existing ObjectStorage steps for the DeadLetterQueue.

Because the DlqLoader may batch multiple records and the ObjectLoaderPartFormatterStep consumes record one by one, this Adapter flattens a list of DestinationRecordRaw.

Constructors

open override val partitions: Int

open suspend override fun broadcast(value: PipelineEvent<K, DlqStepOutput>)

open suspend override fun close()

open override fun consume(partition: Int): Flow<PipelineEvent<K, DlqStepOutput>>

open suspend override fun publish(value: PipelineEvent<K, DlqStepOutput>, partition: Int)