Package io.debezium.connector.base

Class ChangeEventQueue.Builder<T extends Sizeable>

java.lang.Object

io.debezium.connector.base.ChangeEventQueue.Builder<T>

Enclosing class:

ChangeEventQueue<T extends Sizeable>

public static class ChangeEventQueue.Builder<T extends Sizeable>
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private boolean	buffering
private Supplier<LoggingContext.PreviousContext>	loggingContextSupplier
private int	maxBatchSize
private int	maxQueueSize
private long	maxQueueSizeInBytes
private Duration	pollInterval
private QueueProvider<T>	queueProvider

Constructor Summary

Constructors

Constructor	Description
Builder()

Method Summary

Modifier and Type	Method	Description
ChangeEventQueue.Builder<T>	buffering()
ChangeEventQueue<T>	build()
ChangeEventQueue.Builder<T>	loggingContextSupplier(Supplier<LoggingContext.PreviousContext> loggingContextSupplier)
ChangeEventQueue.Builder<T>	maxBatchSize(int maxBatchSize)
ChangeEventQueue.Builder<T>	maxQueueSize(int maxQueueSize)
ChangeEventQueue.Builder<T>	maxQueueSizeInBytes(long maxQueueSizeInBytes)
ChangeEventQueue.Builder<T>	pollInterval(Duration pollInterval)
ChangeEventQueue.Builder<T>	queueProvider(QueueProvider<T> queueProvider)	Sets a custom QueueProvider implementation to be used by the ChangeEventQueue.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

pollInterval

private Duration pollInterval

maxQueueSize

private int maxQueueSize

maxBatchSize

private int maxBatchSize

loggingContextSupplier

private Supplier<LoggingContext.PreviousContext> loggingContextSupplier

maxQueueSizeInBytes

private long maxQueueSizeInBytes

buffering

private boolean buffering

queueProvider

private QueueProvider<T extends Sizeable> queueProvider

Constructor Details

Builder

public Builder()

Method Details

pollInterval

public ChangeEventQueue.Builder<T> pollInterval(Duration pollInterval)

maxQueueSize

public ChangeEventQueue.Builder<T> maxQueueSize(int maxQueueSize)

maxBatchSize

public ChangeEventQueue.Builder<T> maxBatchSize(int maxBatchSize)

loggingContextSupplier

public ChangeEventQueue.Builder<T> loggingContextSupplier(Supplier<LoggingContext.PreviousContext> loggingContextSupplier)

maxQueueSizeInBytes

public ChangeEventQueue.Builder<T> maxQueueSizeInBytes(long maxQueueSizeInBytes)

queueProvider

public ChangeEventQueue.Builder<T> queueProvider(QueueProvider<T> queueProvider)

Sets a custom QueueProvider implementation to be used by the ChangeEventQueue.

If not set, a default provider will be used internally based on the max queue size. This allows for custom queue behavior or instrumentation if needed.

Parameters:

queueProvider - the queue provider to use; may be null, in which case a default will be used

Returns:

this builder instance for method chaining

buffering

public ChangeEventQueue.Builder<T> buffering()

build

public ChangeEventQueue<T> build()