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

Class AmqpSourceTask

java.lang.Object
org.apache.kafka.connect.source.SourceTask
io.aiven.commons.kafka.connector.source.AbstractSourceTask
io.aiven.kafka.connect.amqp.source.AmqpSourceTask
All Implemented Interfaces:
org.apache.kafka.connect.connector.Task
public final class AmqpSourceTask extends io.aiven.commons.kafka.connector.source.AbstractSourceTask
The AMQP source task.

  • Nested Class Summary

    Nested classes/interfaces inherited from class org.apache.kafka.connect.source.SourceTask

    org.apache.kafka.connect.source.SourceTask.TransactionBoundary

  • Field Summary

    Fields inherited from class io.aiven.commons.kafka.connector.source.AbstractSourceTask

    MAX_POLL_TIME, NULL_RESULT

    Fields inherited from class org.apache.kafka.connect.source.SourceTask

    context, TRANSACTION_BOUNDARY_CONFIG

  • Constructor Summary

    Constructors
    Constructor
    Description
    AmqpSourceTask()
    Default constructor.

  • Method Summary

    Modifier and Type
    Method
    Description
    protected void
    closeResources()
     
    protected AmqpSourceConfig
    configure(Map<String,String> props, io.aiven.commons.kafka.connector.source.OffsetManager offsetManager)
     
    protected io.aiven.commons.kafka.connector.source.EvolvingSourceRecordIterator
    getIterator(io.aiven.commons.kafka.connector.source.config.SourceCommonConfig config)
     
    String
    version()
     

    Methods inherited from class io.aiven.commons.kafka.connector.source.AbstractSourceTask

    isRunning, lastEvolution, poll, start, stillPolling, stop

    Methods inherited from class org.apache.kafka.connect.source.SourceTask

    commit, commitRecord, commitRecord, initialize

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • AmqpSourceTask

      public AmqpSourceTask()
      Default constructor.

  • Method Details

    • configure

      protected AmqpSourceConfig configure(Map<String,String> props, io.aiven.commons.kafka.connector.source.OffsetManager offsetManager)
      Specified by:
      configure in class io.aiven.commons.kafka.connector.source.AbstractSourceTask

    • getIterator

      protected io.aiven.commons.kafka.connector.source.EvolvingSourceRecordIterator getIterator(io.aiven.commons.kafka.connector.source.config.SourceCommonConfig config)
      Specified by:
      getIterator in class io.aiven.commons.kafka.connector.source.AbstractSourceTask

    • closeResources

      protected void closeResources()
      Specified by:
      closeResources in class io.aiven.commons.kafka.connector.source.AbstractSourceTask

    • version

      public String version()