CdcPartitionsCreator
class CdcPartitionsCreator<T : Comparable<T>>(val concurrencyResource: ConcurrencyResource, val resourceAcquirer: ResourceAcquirer, val feedBootstrap: GlobalFeedBootstrap, val creatorOps: CdcPartitionsCreatorDebeziumOperations<T>, val readerOps: CdcPartitionReaderDebeziumOperations<T>, val lowerBoundReference: AtomicReference<T>, val upperBoundReference: AtomicReference<T>, val resetReason: AtomicReference<String?>) : PartitionsCreator
PartitionsCreator implementation for CDC with Debezium.
Constructors
Link copied to clipboard
constructor(concurrencyResource: ConcurrencyResource, resourceAcquirer: ResourceAcquirer, feedBootstrap: GlobalFeedBootstrap, creatorOps: CdcPartitionsCreatorDebeziumOperations<T>, readerOps: CdcPartitionReaderDebeziumOperations<T>, lowerBoundReference: AtomicReference<T>, upperBoundReference: AtomicReference<T>, resetReason: AtomicReference<String?>)