Module io.aiven.commons.kafka.config
Package io.aiven.commons.kafka.config.fragment

Class CommonConfigFragment.Setter

java.lang.Object
io.aiven.commons.kafka.config.fragment.AbstractFragmentSetter<CommonConfigFragment.Setter>
io.aiven.commons.kafka.config.fragment.CommonConfigFragment.Setter
Enclosing class:
CommonConfigFragment
public static class CommonConfigFragment.Setter extends AbstractFragmentSetter<CommonConfigFragment.Setter>
Setter to programmatically set values in the configuraiotn.

  • Method Details

    • taskId

      public CommonConfigFragment.Setter taskId(int taskId)
      Sets the task ID value.
      Parameters:
      taskId - the task Id value.
      Returns:
      this

    • maxTasks

      public CommonConfigFragment.Setter maxTasks(int maxTasks)
      Sets the max tasks value.
      Parameters:
      maxTasks - the maximum number of tasks for this connector to run.
      Returns:
      this

    • keyConverter

      public CommonConfigFragment.Setter keyConverter(String keyConverter)
      Set the key Converter
      Parameters:
      keyConverter - the converter to use to convert the key converter
      Returns:
      this

    • valueConverter

      public CommonConfigFragment.Setter valueConverter(String valueConverter)
      Set the value converter
      Parameters:
      valueConverter - the converter to use to convert value data
      Returns:
      this