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

CdcPartitionsCreatorFactory

@Singleton
@Order(value = 10)
class CdcPartitionsCreatorFactory<T : Comparable<T>>(val concurrencyResource: ConcurrencyResource, val resourceAcquirer: ResourceAcquirer, val cdcPartitionsCreatorDbzOps: CdcPartitionsCreatorDebeziumOperations<T>, val cdcPartitionReaderDbzOps: CdcPartitionReaderDebeziumOperations<T>) : PartitionsCreatorFactory

PartitionsCreatorFactory implementation for CDC with Debezium.

Constructors

Link copied to clipboard
constructor(concurrencyResource: ConcurrencyResource, resourceAcquirer: ResourceAcquirer, cdcPartitionsCreatorDbzOps: CdcPartitionsCreatorDebeziumOperations<T>, cdcPartitionReaderDbzOps: CdcPartitionReaderDebeziumOperations<T>)

Functions

Link copied to clipboard
open override fun make(feedBootstrap: FeedBootstrap<*>): PartitionsCreator?