Package io.aiven.kafka.connect.s3

Class AivenKafkaConnectS3SinkConnector

java.lang.Object
org.apache.kafka.connect.connector.Connector
org.apache.kafka.connect.sink.SinkConnector
io.aiven.kafka.connect.s3.AivenKafkaConnectS3SinkConnector
public class AivenKafkaConnectS3SinkConnector extends org.apache.kafka.connect.sink.SinkConnector

  • Constructor Details

    • AivenKafkaConnectS3SinkConnector

      public AivenKafkaConnectS3SinkConnector()

  • Method Details

    • config

      public org.apache.kafka.common.config.ConfigDef config()
      Specified by:
      config in class org.apache.kafka.connect.connector.Connector

    • version

      public String version()
      Specified by:
      version in class org.apache.kafka.connect.connector.Connector

    • taskClass

      public Class<? extends org.apache.kafka.connect.connector.Task> taskClass()
      Specified by:
      taskClass in class org.apache.kafka.connect.connector.Connector

    • taskConfigs

      public List<Map<String,String>> taskConfigs(int maxTasks)
      Specified by:
      taskConfigs in class org.apache.kafka.connect.connector.Connector

    • start

      public void start(Map<String,String> properties)
      Specified by:
      start in class org.apache.kafka.connect.connector.Connector

    • stop

      public void stop()
      Specified by:
      stop in class org.apache.kafka.connect.connector.Connector