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

ConnectorCallback

inner class ConnectorCallback : DebeziumEngine.ConnectorCallback(source)

Constructors

ConnectorCallback

constructor()

Functions

connectorStarted

open override fun connectorStarted()

connectorStopped

open override fun connectorStopped()

open fun pollingStarted()

open fun pollingStopped()

open override fun taskStarted()

open override fun taskStopped()