Airbyte Kotlin Bulk CDK

0.1.92

bulk-cdk-toolkit-extract-cdc/io.airbyte.cdk.command/CdcSourceConfiguration

CdcSourceConfiguration

interface CdcSourceConfiguration : SourceConfiguration

CDC-specific flavor of SourceConfiguration.

Properties

checkpointTargetInterval

abstract val checkpointTargetInterval: Duration

debeziumHeartbeatInterval

abstract val debeziumHeartbeatInterval: Duration

How often Debezium is to emit heartbeat events.

abstract val global: Boolean

abstract val maxConcurrency: Int

maxSnapshotReadDuration

abstract val maxSnapshotReadDuration: Duration?

abstract val realHost: String

abstract val realPort: Int

resourceAcquisitionHeartbeat

abstract val resourceAcquisitionHeartbeat: Duration

sshConnectionOptions

abstract val sshConnectionOptions: SshConnectionOptions

abstract val sshTunnel: SshTunnelMethodConfiguration?

Functions

open fun isCdc(): Boolean