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

Class ConnectorCommonConfigDef

java.lang.Object
org.apache.kafka.common.config.ConfigDef
io.aiven.commons.kafka.config.CommonConfigDef
io.aiven.commons.kafka.connector.common.config.ConnectorCommonConfigDef
Direct Known Subclasses:
SourceCommonConfig.SourceCommonConfigDef
public class ConnectorCommonConfigDef extends io.aiven.commons.kafka.config.CommonConfigDef
The configuration definition for the common connector.

  • Nested Class Summary

    Nested classes/interfaces inherited from class org.apache.kafka.common.config.ConfigDef

    org.apache.kafka.common.config.ConfigDef.CaseInsensitiveValidString, org.apache.kafka.common.config.ConfigDef.CompositeValidator, org.apache.kafka.common.config.ConfigDef.ConfigKey, org.apache.kafka.common.config.ConfigDef.Importance, org.apache.kafka.common.config.ConfigDef.LambdaValidator, org.apache.kafka.common.config.ConfigDef.ListSize, org.apache.kafka.common.config.ConfigDef.NonEmptyString, org.apache.kafka.common.config.ConfigDef.NonEmptyStringWithoutControlChars, org.apache.kafka.common.config.ConfigDef.NonNullValidator, org.apache.kafka.common.config.ConfigDef.Range, org.apache.kafka.common.config.ConfigDef.Recommender, org.apache.kafka.common.config.ConfigDef.Type, org.apache.kafka.common.config.ConfigDef.Validator, org.apache.kafka.common.config.ConfigDef.ValidList, org.apache.kafka.common.config.ConfigDef.ValidString, org.apache.kafka.common.config.ConfigDef.Width

  • Field Summary

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

    NO_DEFAULT_VALUE

  • Constructor Summary

    Constructors
    Constructor
    Description
    ConnectorCommonConfigDef()
    Constructor.

  • Method Summary

    Modifier and Type
    Method
    Description
    protected void
    hideCompressionType(boolean hide)
    This method hides the compression type from documentation but does not make it unconfigurable
    Map<String,org.apache.kafka.common.config.ConfigValue>
    multiValidate(Map<String,org.apache.kafka.common.config.ConfigValue> valueMap)
     

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

    hide, validate

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

    configKeys, convertToString, convertToStringMapWithPasswordValues, defaultValues, define, define, define, define, define, define, define, define, define, define, define, define, define, define, define, define, define, define, defineInternal, defineInternal, embed, getConfigValue, groups, headers, names, parse, parseType, toEnrichedRst, toHtml, toHtml, toHtml, toHtml, toHtmlTable, toHtmlTable, toRst, validateAll, withClientSaslSupport, withClientSslSupport

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Constructor Details

    • ConnectorCommonConfigDef

      public ConnectorCommonConfigDef()
      Constructor.

  • Method Details

    • hideCompressionType

      protected void hideCompressionType(boolean hide)
      This method hides the compression type from documentation but does not make it unconfigurable
      Parameters:
      hide - true hides the key from documentation false shows the config in the documentation

    • multiValidate

      public Map<String,org.apache.kafka.common.config.ConfigValue> multiValidate(Map<String,org.apache.kafka.common.config.ConfigValue> valueMap)
      Overrides:
      multiValidate in class io.aiven.commons.kafka.config.CommonConfigDef