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

Class ConnectorCommonConfig

java.lang.Object
org.apache.kafka.common.config.AbstractConfig
io.aiven.commons.kafka.config.CommonConfig
io.aiven.commons.kafka.connector.common.config.ConnectorCommonConfig
Direct Known Subclasses:
SourceCommonConfig
public class ConnectorCommonConfig extends io.aiven.commons.kafka.config.CommonConfig
The definition of the common connector config functions.

  • Nested Class Summary

    Nested classes/interfaces inherited from class io.aiven.commons.kafka.config.CommonConfig

    io.aiven.commons.kafka.config.CommonConfig.ChangeTrackingMap

  • Field Summary

    Fields inherited from class org.apache.kafka.common.config.AbstractConfig

    AUTOMATIC_CONFIG_PROVIDERS_PROPERTY, CONFIG_PROVIDERS_CONFIG

  • Constructor Summary

    Constructors
    Constructor
    Description
    ConnectorCommonConfig(ConnectorCommonConfigDef configDef, Map<String,String> props)
    Constructor.

  • Method Summary

    Modifier and Type
    Method
    Description
    protected void
    fragmentPostProcess(io.aiven.commons.kafka.config.CommonConfig.ChangeTrackingMap map)
     
    final io.aiven.commons.util.io.compression.CompressionType
    getCompressionType()
    Gets the compression type expected for I/O to storage.
    final String
    getKeyConverterSchemaRegistryUrl()
    Gets the key converter schema registry URL.
    String
    getSchemaRegistryUrl()
    Gets the schema registry URL.
    final String
    getValueConverterSchemaRegistryUrl()
    Gets the value converter schema registry URL.
    final boolean
    isKeyConverterRegistryEnabled()
    Returns true if the key converter schema registry is enabled.
    final boolean
    isSchemaRegistryEnabled()
    Returns true if the schema registry is enabled.
    final boolean
    isValueConverterRegistryEnabled()
    Returns true if the value converter schema registry is enabled.

    Methods inherited from class io.aiven.commons.kafka.config.CommonConfig

    finalize, getKafkaRetryBackoffMs, getMaxTasks, getTaskId, postProcessParsedConfig

    Methods inherited from class org.apache.kafka.common.config.AbstractConfig

    documentationOf, equals, get, getBoolean, getClass, getConfiguredInstance, getConfiguredInstance, getConfiguredInstances, getConfiguredInstances, getConfiguredInstances, getDouble, getInt, getList, getLong, getPassword, getShort, getString, hashCode, ignore, logUnused, nonInternalValues, originals, originals, originalsStrings, originalsWithPrefix, originalsWithPrefix, typeOf, unused, values, valuesWithPrefixAllOrNothing, valuesWithPrefixOverride

    Methods inherited from class java.lang.Object

    clone, getClass, notify, notifyAll, toString, wait, wait, wait

  • Constructor Details

    • ConnectorCommonConfig

      public ConnectorCommonConfig(ConnectorCommonConfigDef configDef, Map<String,String> props)
      Constructor.
      Parameters:
      configDef - the configuration definition.
      props - the map of properties

  • Method Details

    • fragmentPostProcess

      protected void fragmentPostProcess(io.aiven.commons.kafka.config.CommonConfig.ChangeTrackingMap map)
      Overrides:
      fragmentPostProcess in class io.aiven.commons.kafka.config.CommonConfig

    • getSchemaRegistryUrl

      public String getSchemaRegistryUrl()
      Gets the schema registry URL. May return null if not set.
      Returns:
      the schema registry URL or null

    • isSchemaRegistryEnabled

      public final boolean isSchemaRegistryEnabled()
      Returns true if the schema registry is enabled. Schema registry will not be listed as enabled if the URL is null.
      Returns:
      true if the registry is enabled, false otherwise.

    • getValueConverterSchemaRegistryUrl

      public final String getValueConverterSchemaRegistryUrl()
      Gets the value converter schema registry URL. May return null if not set.
      Returns:
      the value converter schema registry URL or null

    • isValueConverterRegistryEnabled

      public final boolean isValueConverterRegistryEnabled()
      Returns true if the value converter schema registry is enabled. Schema registry will not be listed as enabled if the value converter schema registry URL is null.
      Returns:
      true if the value converter registry is enabled, false otherwise.

    • getKeyConverterSchemaRegistryUrl

      public final String getKeyConverterSchemaRegistryUrl()
      Gets the key converter schema registry URL. May return null if not set.
      Returns:
      the key converter schema registry URL or null

    • isKeyConverterRegistryEnabled

      public final boolean isKeyConverterRegistryEnabled()
      Returns true if the key converter schema registry is enabled. Schema registry will not be listed as enabled if the key converter schema registry URL is null.
      Returns:
      true if the key converter registry is enabled, false otherwise.

    • getCompressionType

      public final io.aiven.commons.util.io.compression.CompressionType getCompressionType()
      Gets the compression type expected for I/O to storage.
      Returns:
      the compression type expected for I/O to storage.