Uses of Class
com.github.jcustenborder.kafka.connect.utils.data.SourceRecordDequeBuilder

Packages that use SourceRecordDequeBuilder

Package	Description
com.github.jcustenborder.kafka.connect.utils.data

Uses of SourceRecordDequeBuilder in com.github.jcustenborder.kafka.connect.utils.data

Methods in com.github.jcustenborder.kafka.connect.utils.data that return SourceRecordDequeBuilder

Modifier and Type	Method and Description
SourceRecordDequeBuilder	SourceRecordDequeBuilder.batchSize(int batchSize)
SourceRecordDequeBuilder	SourceRecordDequeBuilder.emptyWaitMs(int emptyWaitMs)
SourceRecordDequeBuilder	SourceRecordDequeBuilder.maximumCapacity(int maximumCapacity)
SourceRecordDequeBuilder	SourceRecordDequeBuilder.maximumCapacityTimeoutMs(int maximumCapacityTimeoutMs)
SourceRecordDequeBuilder	SourceRecordDequeBuilder.maximumCapacityWaitMs(int maximumCapacityWaitMs)
static SourceRecordDequeBuilder	SourceRecordDequeBuilder.of()
SourceRecordDequeBuilder	SourceRecordDequeBuilder.writeRateLimiter(com.google.common.util.concurrent.RateLimiter writeRateLimiter)