Uses of Class
io.aiven.commons.kafka.connector.source.config.SourceConfigFragment.Setter

Packages that use SourceConfigFragment.Setter

Package	Description
io.aiven.commons.kafka.connector.source.config

Uses of SourceConfigFragment.Setter in io.aiven.commons.kafka.connector.source.config

Methods in io.aiven.commons.kafka.connector.source.config that return SourceConfigFragment.Setter

Modifier and Type	Method	Description
SourceConfigFragment.Setter	SourceConfigFragment.Setter.csvExtractorHeaders(String headers)	Sets the headers for the CSV.
SourceConfigFragment.Setter	SourceConfigFragment.Setter.csvExtractorHeadersEnabled(boolean state)	Sets the header flag for the CSV extractor.
SourceConfigFragment.Setter	SourceConfigFragment.Setter.distributionType(DistributionType distributionType)	Sets the distribution type.
SourceConfigFragment.Setter	SourceConfigFragment.Setter.errorsTolerance(org.apache.kafka.connect.runtime.errors.ToleranceType tolerance)	Sets the error tolerance.
SourceConfigFragment.Setter	SourceConfigFragment.Setter.extractorBuffer(int bufferSize)	Sets the extractor buffer size.
SourceConfigFragment.Setter	SourceConfigFragment.Setter.extractorCache(int cacheSize)	Sets the cache size in bytes.
SourceConfigFragment.Setter	SourceConfigFragment.Setter.extractorClass(Class<? extends Extractor> extractor)	Sets the extractor class for this source.
SourceConfigFragment.Setter	SourceConfigFragment.Setter.maxPollRecords(int maxPollRecords)	Set the maximum poll records.
SourceConfigFragment.Setter	SourceConfigFragment.Setter.nativeStartKey(String nativeStartKey)	Sets the initial native key to start from.
SourceConfigFragment.Setter	SourceConfigFragment.Setter.ringBufferSize(int ringBufferSize)	Sets the ring buffer size.
static SourceConfigFragment.Setter	SourceConfigFragment.setter(Map<String,String> data)	Creates a Setter for this fragment.
SourceConfigFragment.Setter	SourceConfigFragment.Setter.targetTopic(String targetTopic)	Sets the target topic.