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

Class SourceConfigFragment.Setter

java.lang.Object
io.aiven.commons.kafka.config.fragment.AbstractFragmentSetter<SourceConfigFragment.Setter>
io.aiven.commons.kafka.connector.source.config.SourceConfigFragment.Setter
Enclosing class:
SourceConfigFragment
public static class SourceConfigFragment.Setter extends io.aiven.commons.kafka.config.fragment.AbstractFragmentSetter<SourceConfigFragment.Setter>
The SourceConfigFragment setter.

  • Constructor Details

    • Setter

      protected Setter(Map<String,String> data)
      Constructor.
      Parameters:
      data - the data to modify.

  • Method Details

    • maxPollRecords

      public SourceConfigFragment.Setter maxPollRecords(int maxPollRecords)
      Set the maximum poll records.
      Parameters:
      maxPollRecords - the maximum number of records to poll.
      Returns:
      this

    • errorsTolerance

      public SourceConfigFragment.Setter errorsTolerance(org.apache.kafka.connect.runtime.errors.ToleranceType tolerance)
      Sets the error tolerance.
      Parameters:
      tolerance - the error tolerance
      Returns:
      this.

    • targetTopic

      public SourceConfigFragment.Setter targetTopic(String targetTopic)
      Sets the target topic.
      Parameters:
      targetTopic - the target topic.
      Returns:
      this.

    • distributionType

      public SourceConfigFragment.Setter distributionType(DistributionType distributionType)
      Sets the distribution type.
      Parameters:
      distributionType - the distribution type.
      Returns:
      this

    • ringBufferSize

      public SourceConfigFragment.Setter ringBufferSize(int ringBufferSize)
      Sets the ring buffer size.
      Parameters:
      ringBufferSize - the ring buffer size
      Returns:
      this.

    • nativeStartKey

      public SourceConfigFragment.Setter nativeStartKey(String nativeStartKey)
      Sets the initial native key to start from.
      Parameters:
      nativeStartKey - the key to start reading new messages from.
      Returns:
      this.

    • extractorClass

      public SourceConfigFragment.Setter extractorClass(Class<? extends Extractor> extractor)
      Sets the extractor class for this source.
      Parameters:
      extractor - the class of the Extractor for this source.
      Returns:
      the extractor for this source.

    • extractorBuffer

      public SourceConfigFragment.Setter extractorBuffer(int bufferSize)
      Sets the extractor buffer size.
      Parameters:
      bufferSize - the buffer size in bytes.
      Returns:
      this.

    • extractorCache

      public SourceConfigFragment.Setter extractorCache(int cacheSize)
      Sets the cache size in bytes.
      Parameters:
      cacheSize - the cache size in bytes.
      Returns:
      this

    • csvExtractorHeadersEnabled

      public SourceConfigFragment.Setter csvExtractorHeadersEnabled(boolean state)
      Sets the header flag for the CSV extractor.
      Parameters:
      state - the state for the header flag.
      Returns:
      this

    • csvExtractorHeaders

      public SourceConfigFragment.Setter csvExtractorHeaders(String headers)
      Sets the headers for the CSV. Should be a comma separated list of field names.
      Parameters:
      headers - the header names.
      Returns:
      this