Package io.aiven.kafka.connect.s3

Class S3SinkTask

java.lang.Object
org.apache.kafka.connect.sink.SinkTask
io.aiven.kafka.connect.s3.S3SinkTask
All Implemented Interfaces:
org.apache.kafka.connect.connector.Task
public final class S3SinkTask extends org.apache.kafka.connect.sink.SinkTask

  • Field Summary

    Fields inherited from class org.apache.kafka.connect.sink.SinkTask

    context, TOPICS_CONFIG, TOPICS_REGEX_CONFIG

  • Constructor Summary

    Constructors
    Constructor
    Description
    S3SinkTask()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    flush(Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata> offsets)
     
    void
    put(Collection<org.apache.kafka.connect.sink.SinkRecord> records)
     
    void
    start(Map<String,String> props)
     
    void
    stop()
     
    String
    version()
     

    Methods inherited from class org.apache.kafka.connect.sink.SinkTask

    close, initialize, onPartitionsAssigned, onPartitionsRevoked, open, preCommit

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • S3SinkTask

      public S3SinkTask()

  • Method Details

    • start

      public void start(Map<String,String> props)
      Specified by:
      start in interface org.apache.kafka.connect.connector.Task
      Specified by:
      start in class org.apache.kafka.connect.sink.SinkTask

    • put

      public void put(Collection<org.apache.kafka.connect.sink.SinkRecord> records)
      Specified by:
      put in class org.apache.kafka.connect.sink.SinkTask

    • flush

      public void flush(Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata> offsets)
      Overrides:
      flush in class org.apache.kafka.connect.sink.SinkTask

    • stop

      public void stop()
      Specified by:
      stop in interface org.apache.kafka.connect.connector.Task
      Specified by:
      stop in class org.apache.kafka.connect.sink.SinkTask

    • version

      public String version()