Package io.aiven.kafka.connect.common.config

Class SourceConfigFragment.Setter

java.lang.Object
io.aiven.kafka.connect.common.config.AbstractFragmentSetter<SourceConfigFragment.Setter>
io.aiven.kafka.connect.common.config.SourceConfigFragment.Setter
Enclosing class:
SourceConfigFragment
public static class SourceConfigFragment.Setter extends 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(ErrorsTolerance 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.