Airbyte Kotlin Bulk CDK

0.1.92

bulk-cdk-toolkit-extract-cdc/io.airbyte.cdk.read.cdc/CdcPartitionReader

CdcPartitionReader

class CdcPartitionReader<T : Comparable<T>>(val resourceAcquirer: ResourceAcquirer, val readerOps: CdcPartitionReaderDebeziumOperations<T>, val upperBound: T, val debeziumProperties: Map<String, String>, val startingOffset: DebeziumOffset, val startingSchemaHistory: DebeziumSchemaHistory?, val isInputStateSynthetic: Boolean, val feedBootstrap: GlobalFeedBootstrap) : UnlimitedTimePartitionReader

PartitionReader implementation for CDC with Debezium.

Constructors

CdcPartitionReader

constructor(resourceAcquirer: ResourceAcquirer, readerOps: CdcPartitionReaderDebeziumOperations<T>, upperBound: T, debeziumProperties: Map<String, String>, startingOffset: DebeziumOffset, startingSchemaHistory: DebeziumSchemaHistory?, isInputStateSynthetic: Boolean, feedBootstrap: GlobalFeedBootstrap)

Types

AcquiredResource

interface AcquiredResource : AutoCloseable

enum CloseReason : Enum<CdcPartitionReader.CloseReason>

CompletionCallback

inner class CompletionCallback : DebeziumEngine.CompletionCallback

ConnectorCallback

inner class ConnectorCallback : DebeziumEngine.ConnectorCallback

inner class EventConsumer : Consumer<ChangeEvent<String?, String?>>

Properties

debeziumProperties

val debeziumProperties: Map<String, String>

val feedBootstrap: GlobalFeedBootstrap

isInputStateSynthetic

val isInputStateSynthetic: Boolean

outputMessageRouter

lateinit var outputMessageRouter: OutputMessageRouter

val readerOps: CdcPartitionReaderDebeziumOperations<T>

resourceAcquirer

val resourceAcquirer: ResourceAcquirer

val startingOffset: DebeziumOffset

startingSchemaHistory

val startingSchemaHistory: DebeziumSchemaHistory?

val upperBound: T

Functions

open override fun checkpoint(): PartitionReadCheckpoint

releaseResources

open override fun releaseResources()

open suspend override fun run()

tryAcquireResources

open override fun tryAcquireResources(): PartitionReader.TryAcquireResourcesStatus