Class TransformerFragment.Setter

java.lang.Object
io.aiven.kafka.connect.common.config.AbstractFragmentSetter<TransformerFragment.Setter>
io.aiven.kafka.connect.common.config.TransformerFragment.Setter
Enclosing class:
TransformerFragment

public static final class TransformerFragment.Setter extends AbstractFragmentSetter<TransformerFragment.Setter>
The setter for the TransformerFragment
  • Method Details

    • schemaRegistry

      public TransformerFragment.Setter schemaRegistry(String schemaRegistryUrl)
      Sets the schema registry URL.
      Parameters:
      schemaRegistryUrl - the schema registry URL.
      Returns:
      this
    • valueConverterSchemaRegistry

      public TransformerFragment.Setter valueConverterSchemaRegistry(String valueConverterSchemaRegistryUrl)
      Sets the schema registry for the value converter schema registry URL.
      Parameters:
      valueConverterSchemaRegistryUrl - the schema registry URL.
      Returns:
      this
    • inputFormat

      public TransformerFragment.Setter inputFormat(InputFormat inputFormat)
      Sets the input format.
      Parameters:
      inputFormat - the input format for the transformer.
      Returns:
      this
    • maxBufferSize

      public TransformerFragment.Setter maxBufferSize(int maxBufferSize)
      Sets the max buffer size for a BYTE transformer.
      Parameters:
      maxBufferSize - the maximum buffer size.
      Returns:
      this