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

Package-level declarations

Functions

Link copied to clipboard
fun DestinationStream.newDlqRecord(data: Map<String, Any>): DestinationRecordRaw

A helper method to generate a new DestinationRecordRaw for a dead letter queue.

Link copied to clipboard
fun DestinationRecordRaw.toDlqRecord(data: Map<String, Any>, keepOriginalFields: Boolean = true): DestinationRecordRaw

A helper method to modify a existing DestinationRecordRaw for a dead letter queue.