Package io.debezium.connector.base
package io.debezium.connector.base
-
ClassDescriptionChangeEventQueue<T extends Sizeable>A queue which serves as handover point between producer threads (e.g.ChangeEventQueue.Builder<T extends Sizeable>DefaultQueueProvider<T extends Sizeable>Default implementation of
QueueProviderusing anArrayDeque.Provides queue operations for change events.Service that provides the resolvedQueueProviderinstance for buffering change events.An implementation of theServiceProvidercontract for theQueueProviderService.