Stream
data class StreamSourceConfigMysqlSourceConfig(val binaryLogPosition: StreamSourceConfigMysqlSourceConfigBinaryLogPosition? = null, val excludeObjects: StreamSourceConfigMysqlSourceConfigExcludeObjects? = null, val gtid: StreamSourceConfigMysqlSourceConfigGtid? = null, val includeObjects: StreamSourceConfigMysqlSourceConfigIncludeObjects? = null, val maxConcurrentBackfillTasks: Int? = null, val maxConcurrentCdcTasks: Int? = null)
Constructors
Link copied to clipboard
constructor(binaryLogPosition: StreamSourceConfigMysqlSourceConfigBinaryLogPosition? = null, excludeObjects: StreamSourceConfigMysqlSourceConfigExcludeObjects? = null, gtid: StreamSourceConfigMysqlSourceConfigGtid? = null, includeObjects: StreamSourceConfigMysqlSourceConfigIncludeObjects? = null, maxConcurrentBackfillTasks: Int? = null, maxConcurrentCdcTasks: Int? = null)
Properties
Link copied to clipboard
CDC reader reads from binary logs replication cdc method.
Link copied to clipboard
MySQL objects to exclude from the stream. Structure is documented below.
Link copied to clipboard
CDC reader reads from gtid based replication.
Link copied to clipboard
MySQL objects to retrieve from the source. Structure is documented below.
Link copied to clipboard
Maximum number of concurrent backfill tasks. The number should be non negative. If not set (or set to 0), the system's default value will be used.
Link copied to clipboard
Maximum number of concurrent CDC tasks. The number should be non negative. If not set (or set to 0), the system's default value will be used.