Package io.aiven.kafka.connect.azure.sink

Class AzureBlobSinkTask

java.lang.Object
org.apache.kafka.connect.sink.SinkTask
io.aiven.kafka.connect.azure.sink.AzureBlobSinkTask
All Implemented Interfaces:
org.apache.kafka.connect.connector.Task
public final class AzureBlobSinkTask 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
    AzureBlobSinkTask()
     
    AzureBlobSinkTask(Map<String,String> props, com.azure.storage.blob.BlobServiceClient blobServiceClient)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    flush(Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata> currentOffsets)
     
    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

    • AzureBlobSinkTask

      public AzureBlobSinkTask()

    • AzureBlobSinkTask

      public AzureBlobSinkTask(Map<String,String> props, com.azure.storage.blob.BlobServiceClient blobServiceClient)

  • 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> currentOffsets)
      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()