Package io.aiven.kafka.connect.amqp.source.config

Class AmqpSourceConfigDef

java.lang.Object
org.apache.kafka.common.config.ConfigDef
io.aiven.commons.kafka.config.CommonConfigDef
io.aiven.commons.kafka.connector.common.config.ConnectorCommonConfigDef
io.aiven.commons.kafka.connector.source.config.SourceCommonConfig.SourceCommonConfigDef
io.aiven.kafka.connect.amqp.source.config.AmqpSourceConfigDef
public final class AmqpSourceConfigDef extends io.aiven.commons.kafka.connector.source.config.SourceCommonConfig.SourceCommonConfigDef
The configuration file for the AMQP source.

  • 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
    AmqpSourceConfigDef()
    Constructor.

  • Method Summary

    Modifier and Type
    Method
    Description
    Map<String,org.apache.kafka.common.config.ConfigValue>
    multiValidate(Map<String,org.apache.kafka.common.config.ConfigValue> valueMap)
    Validates the AMQP configuration is correct and meets requirements

    Methods inherited from class io.aiven.commons.kafka.connector.source.config.SourceCommonConfig.SourceCommonConfigDef

    hideDistributionType, hideExtractorBuffer, hideExtractorCacheSize, hideExtractorCSVHeaders, hideExtractorCSVHeadersEnabled, hideExtractorExtractorClass, hideNativeStartKey, hideRingBufferSize

    Methods inherited from class io.aiven.commons.kafka.connector.common.config.ConnectorCommonConfigDef

    hideCompressionType

    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

    • AmqpSourceConfigDef

      public AmqpSourceConfigDef()
      Constructor.

  • Method Details

    • multiValidate

      public Map<String,org.apache.kafka.common.config.ConfigValue> multiValidate(Map<String,org.apache.kafka.common.config.ConfigValue> valueMap)
      Validates the AMQP configuration is correct and meets requirements
      Overrides:
      multiValidate in class io.aiven.commons.kafka.connector.source.config.SourceCommonConfig.SourceCommonConfigDef
      Parameters:
      valueMap - the map of configuration names to values.
      Returns:
      the updated map.