Uses of Class
io.aiven.commons.kafka.connector.source.config.SourceConfigFragment.Setter
Packages that use SourceConfigFragment.Setter
-
Uses of SourceConfigFragment.Setter in io.aiven.commons.kafka.connector.source.config
Methods in io.aiven.commons.kafka.connector.source.config that return SourceConfigFragment.SetterModifier and TypeMethodDescriptionSourceConfigFragment.Setter.csvExtractorHeaders(String headers) Sets the headers for the CSV.SourceConfigFragment.Setter.csvExtractorHeadersEnabled(boolean state) Sets the header flag for the CSV extractor.SourceConfigFragment.Setter.distributionType(DistributionType distributionType) Sets the distribution type.SourceConfigFragment.Setter.errorsTolerance(org.apache.kafka.connect.runtime.errors.ToleranceType tolerance) Sets the error tolerance.SourceConfigFragment.Setter.extractorBuffer(int bufferSize) Sets the extractor buffer size.SourceConfigFragment.Setter.extractorCache(int cacheSize) Sets the cache size in bytes.SourceConfigFragment.Setter.extractorClass(Class<? extends Extractor> extractor) Sets the extractor class for this source.SourceConfigFragment.Setter.maxPollRecords(int maxPollRecords) Set the maximum poll records.SourceConfigFragment.Setter.nativeStartKey(String nativeStartKey) Sets the initial native key to start from.SourceConfigFragment.Setter.ringBufferSize(int ringBufferSize) Sets the ring buffer size.static SourceConfigFragment.SetterCreates a Setter for this fragment.SourceConfigFragment.Setter.targetTopic(String targetTopic) Sets the target topic.