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

Class ConnectorCommonConfigFragment.Setter

java.lang.Object
io.aiven.commons.kafka.config.fragment.AbstractFragmentSetter<ConnectorCommonConfigFragment.Setter>
io.aiven.commons.kafka.connector.common.config.ConnectorCommonConfigFragment.Setter
Enclosing class:
ConnectorCommonConfigFragment
public static class ConnectorCommonConfigFragment.Setter extends io.aiven.commons.kafka.config.fragment.AbstractFragmentSetter<ConnectorCommonConfigFragment.Setter>
Gets the setter for this fragment.

  • Constructor Details

    • Setter

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

  • Method Details

    • schemaRegistry

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

    • schemaRegistry

      public ConnectorCommonConfigFragment.Setter schemaRegistry(URI schemaRegistryUri)
      Sets the schema registry URL.
      Parameters:
      schemaRegistryUri - the schema registry URL
      Returns:
      this.

    • enableSchemaRegistry

      public ConnectorCommonConfigFragment.Setter enableSchemaRegistry(boolean enableSchemaRegistry)
      Sets the schema registry flag.
      Parameters:
      enableSchemaRegistry - the state of the schema registry flag.
      Returns:
      this

    • valueConverterSchemaRegistry

      public ConnectorCommonConfigFragment.Setter valueConverterSchemaRegistry(String registryUrl)
      Sets the value converter schema registry URL.
      Parameters:
      registryUrl - the value converter schema registry URL
      Returns:
      this.

    • valueConverterSchemaRegistry

      public ConnectorCommonConfigFragment.Setter valueConverterSchemaRegistry(URI registryUri)
      Sets the value converter schema registry URL.
      Parameters:
      registryUri - the value converter schema registry URL
      Returns:
      this.

    • enableValueConverterRegistry

      public ConnectorCommonConfigFragment.Setter enableValueConverterRegistry(boolean enableRegistry)
      Sets the value converter schema registry flag.
      Parameters:
      enableRegistry - the state of the value converter schema registry flag.
      Returns:
      this

    • keyConverterSchemaRegistry

      public ConnectorCommonConfigFragment.Setter keyConverterSchemaRegistry(String registryUrl)
      Sets the key converter schema registry URL.
      Parameters:
      registryUrl - the key converter schema registry URL
      Returns:
      this.

    • keyConverterSchemaRegistry

      public ConnectorCommonConfigFragment.Setter keyConverterSchemaRegistry(URI registryUri)
      Sets the key converter schema registry URL.
      Parameters:
      registryUri - the key converter schema registry URL
      Returns:
      this.

    • enableKeyConverterRegistry

      public ConnectorCommonConfigFragment.Setter enableKeyConverterRegistry(boolean enableRegistry)
      Sets the value converter schema registry flag.
      Parameters:
      enableRegistry - the state of the key converter schema registry flag.
      Returns:
      this

    • compressionType

      public ConnectorCommonConfigFragment.Setter compressionType(io.aiven.commons.util.io.compression.CompressionType compressionType)
      Sets the compression type expected for I/O to storage.
      Parameters:
      compressionType - the compression type expected for I/O to storage.
      Returns:
      this