Class Hierarchy

  • java.lang.Object
    • org.apache.kafka.common.config.AbstractConfig
      • io.aiven.kafka.connect.common.config.CommonConfig
        • io.aiven.kafka.connect.common.config.SourceCommonConfig
    • io.aiven.kafka.connect.common.source.AbstractSourceRecord<K,N,O,E>
    • io.aiven.kafka.connect.common.source.AbstractSourceRecordIterator<N,K,O,T> (implements java.util.Iterator<E>)
    • io.aiven.kafka.connect.s3.source.utils.AWSV2SourceClient
    • org.apache.kafka.common.config.ConfigDef
    • org.apache.kafka.connect.connector.Connector (implements org.apache.kafka.connect.components.Versioned)
      • org.apache.kafka.connect.source.SourceConnector
    • io.aiven.kafka.connect.s3.source.config.S3ClientFactory
    • io.aiven.kafka.connect.s3.source.utils.S3OffsetManagerEntry (implements io.aiven.kafka.connect.common.source.OffsetManager.OffsetManagerEntry<T>)
    • org.apache.kafka.connect.source.SourceTask (implements org.apache.kafka.connect.connector.Task)
      • io.aiven.kafka.connect.common.source.AbstractSourceTask
    • io.aiven.kafka.connect.s3.source.utils.Version