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

Class AmqpSinkConfigDef

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.kafka.connect.amqp.sink.config.AmqpSinkConfigDef
public class AmqpSinkConfigDef extends io.aiven.commons.kafka.connector.common.config.ConnectorCommonConfigDef
The configuration definition for AMQP sink.

  • Nested Class Summary

    Nested Classes
    Modifier and Type
    Class
    Description
    static class 
    AmqpSinkConfigDef.Setter
    The Setter for the AMQP sink specific options.

    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
    AmqpSinkConfigDef()
    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.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

    • AmqpSinkConfigDef

      public AmqpSinkConfigDef()
      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.common.config.ConnectorCommonConfigDef
      Parameters:
      valueMap - the map of configuration names to values.
      Returns:
      the updated map.