Airbyte Kotlin Bulk CDK

0.1.92

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

DebeziumPropertiesBuilder

class DebeziumPropertiesBuilder(props: Properties = Properties())

Utility class for building Properties for initializing the Debezium engine.

Constructors

DebeziumPropertiesBuilder

constructor(props: Properties = Properties())

Types

object Companion

Properties

expectsOffsetFile

val expectsOffsetFile: Boolean

expectsSchemaHistoryFile

val expectsSchemaHistoryFile: Boolean

Functions

fun build(): Properties

fun buildMap(): Map<String, String>

fun with(properties: Map<*, *>): DebeziumPropertiesBuilder

fun with(key: String, value: String): DebeziumPropertiesBuilder

fun withConnector(connectorClass: Class<out Connector>): DebeziumPropertiesBuilder

fun withConverters(vararg converters: Class<out RelationalColumnCustomConverter>): DebeziumPropertiesBuilder

fun withConverters(vararg converters: KClass<out RelationalColumnCustomConverter>): DebeziumPropertiesBuilder

fun withDatabase(properties: Map<*, *>): DebeziumPropertiesBuilder

fun withDatabase(key: String, value: String): DebeziumPropertiesBuilder

withDebeziumName

fun withDebeziumName(name: String): DebeziumPropertiesBuilder

fun withDefault(): DebeziumPropertiesBuilder

fun withHeartbeats(heartbeatInterval: Duration): DebeziumPropertiesBuilder

fun withOffset(): DebeziumPropertiesBuilder

fun withOffsetFile(offsetFilePath: Path): DebeziumPropertiesBuilder

withSchemaHistory

fun withSchemaHistory(): DebeziumPropertiesBuilder

withSchemaHistoryFile

fun withSchemaHistoryFile(schemaFilePath: Path): DebeziumPropertiesBuilder

fun withStreams(streams: List<Stream>): DebeziumPropertiesBuilder

Tells Debezium which tables and columns we care about.