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

Class AmqpSourceConfig

java.lang.Object
org.apache.kafka.common.config.AbstractConfig
io.aiven.commons.kafka.config.CommonConfig
io.aiven.commons.kafka.connector.common.config.ConnectorCommonConfig
io.aiven.commons.kafka.connector.source.config.SourceCommonConfig
io.aiven.kafka.connect.amqp.source.config.AmqpSourceConfig
All Implemented Interfaces:
AmqpCommonConfig
public class AmqpSourceConfig extends io.aiven.commons.kafka.connector.source.config.SourceCommonConfig implements AmqpCommonConfig
The configuration for an AMQP Source connector.

  • Nested Class Summary

    Nested classes/interfaces inherited from class io.aiven.commons.kafka.connector.source.config.SourceCommonConfig

    io.aiven.commons.kafka.connector.source.config.SourceCommonConfig.Documentation, io.aiven.commons.kafka.connector.source.config.SourceCommonConfig.SourceCommonConfigDef

    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
    AmqpSourceConfig(Map<String,String> originals)
    Constructor.

  • Method Summary

    Modifier and Type
    Method
    Description
    org.apache.qpid.protonj2.client.Client
    getClient()
    Creates a AMQP client.
    org.apache.qpid.protonj2.client.Connection
    getConnection(org.apache.qpid.protonj2.client.Client client)
    Creates a new Connection to an AMQP client.
    AmqpFormat
    getMessageFormat()
    Gets the expected format for the AMQP message.
    org.apache.qpid.protonj2.client.Receiver
    getReceiver(org.apache.qpid.protonj2.client.Connection connection)
    Creates a new AMQP Receiver.
    org.apache.qpid.protonj2.client.Sender
    getSender(org.apache.qpid.protonj2.client.Connection connection)
    Creates a new AMQP Sender.
    boolean
    isStream()
    Determins if we are processing a stream.

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

    getCsvExtractorHeader, getDistributionType, getErrorsTolerance, getExtractor, getExtractorBufferSize, getExtractorCacheSize, getMaxPollRecords, getNativeStartKey, getRingBufferSize, getTargetTopic, isCsvExtractorHeaderEnabled

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

    fragmentPostProcess, getCompressionType, getKeyConverterSchemaRegistryUrl, getSchemaRegistryUrl, getValueConverterSchemaRegistryUrl, isKeyConverterRegistryEnabled, isSchemaRegistryEnabled, isValueConverterRegistryEnabled

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

    finalize, getKafkaRetryBackoffMs, getKeyConverter, getMaxTasks, getTaskId, getValueConverter, 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

    Methods inherited from interface io.aiven.kafka.connect.amqp.common.config.AmqpCommonConfig

    getReceiver, getSender

  • Constructor Details

    • AmqpSourceConfig

      public AmqpSourceConfig(Map<String,String> originals)
      Constructor.
      Parameters:
      originals - the initial configuration data.

  • Method Details

    • getReceiver

      public org.apache.qpid.protonj2.client.Receiver getReceiver(org.apache.qpid.protonj2.client.Connection connection) throws org.apache.qpid.protonj2.client.exceptions.ClientException, ExecutionException, InterruptedException
      Description copied from interface: AmqpCommonConfig
      Creates a new AMQP Receiver.
      Specified by:
      getReceiver in interface AmqpCommonConfig
      Parameters:
      connection - the AMQP connection to use for the receiver.
      Returns:
      the new AMQP Receiver. Must be closed when finished.
      Throws:
      org.apache.qpid.protonj2.client.exceptions.ClientException - if the AMQP receiver can not be created.
      ExecutionException - If the receiver could not be created.
      InterruptedException - If the remote server was interrupted.

    • getSender

      public org.apache.qpid.protonj2.client.Sender getSender(org.apache.qpid.protonj2.client.Connection connection) throws org.apache.qpid.protonj2.client.exceptions.ClientException, ExecutionException, InterruptedException
      Description copied from interface: AmqpCommonConfig
      Creates a new AMQP Sender.
      Specified by:
      getSender in interface AmqpCommonConfig
      Parameters:
      connection - the AMQP connection to use for the sender.
      Returns:
      the new AMQP sender. Must be closed when finished.
      Throws:
      org.apache.qpid.protonj2.client.exceptions.ClientException - if the AMQP sender can not be created.
      ExecutionException - If the sender could not be created.
      InterruptedException - If the remote server was interrupted.

    • getClient

      public org.apache.qpid.protonj2.client.Client getClient()
      Description copied from interface: AmqpCommonConfig
      Creates a AMQP client. Must be closed when finished.
      Specified by:
      getClient in interface AmqpCommonConfig
      Returns:
      a newly constructed client.

    • getConnection

      public org.apache.qpid.protonj2.client.Connection getConnection(org.apache.qpid.protonj2.client.Client client) throws org.apache.qpid.protonj2.client.exceptions.ClientException
      Description copied from interface: AmqpCommonConfig
      Creates a new Connection to an AMQP client.
      Specified by:
      getConnection in interface AmqpCommonConfig
      Parameters:
      client - the client to connect to.
      Returns:
      the Connection. Must be closed when finished.
      Throws:
      org.apache.qpid.protonj2.client.exceptions.ClientException - if the AMQP connection can not be established.

    • getMessageFormat

      public AmqpFormat getMessageFormat()
      Description copied from interface: AmqpCommonConfig
      Gets the expected format for the AMQP message. This is the conversion strategy AMQP and Kafka message formats.
      Specified by:
      getMessageFormat in interface AmqpCommonConfig
      Returns:
      the expected Amqp message format.

    • isStream

      public boolean isStream()
      Determins if we are processing a stream.
      Returns:
      true if the AMQP messages are from a stram, false if they are not.