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()
     
    void
    commitRecord(org.apache.kafka.connect.source.SourceRecord record, org.apache.kafka.clients.producer.RecordMetadata metadata)
     
    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)
     
    io.aiven.commons.kafka.connector.source.EvolvingSourceRecord
    lastEvolution(io.aiven.commons.kafka.connector.source.EvolvingSourceRecord record)
     
    String
    version()
     

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

    isRunning, poll, start, stillPolling, stop

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

    commit, 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()

    • commitRecord

      public void commitRecord(org.apache.kafka.connect.source.SourceRecord record, org.apache.kafka.clients.producer.RecordMetadata metadata)
      Overrides:
      commitRecord in class org.apache.kafka.connect.source.SourceTask

    • lastEvolution

      public io.aiven.commons.kafka.connector.source.EvolvingSourceRecord lastEvolution(io.aiven.commons.kafka.connector.source.EvolvingSourceRecord record)
      Overrides:
      lastEvolution in class io.aiven.commons.kafka.connector.source.AbstractSourceTask