Class Hierarchy

  • java.lang.Object
    • java.util.AbstractCollection<E> (implements java.util.Collection<E>)
      • org.apache.commons.collections.buffer.BoundedFifoBuffer (implements org.apache.commons.collections.BoundedCollection, org.apache.commons.collections.Buffer, java.io.Serializable)
        • org.apache.commons.collections.buffer.CircularFifoBuffer
          • io.aiven.kafka.connect.s3.source.utils.RingBuffer
    • org.apache.kafka.common.config.AbstractConfig
      • io.aiven.kafka.connect.common.config.CommonConfig
        • io.aiven.kafka.connect.common.config.SourceCommonConfig
    • 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>)
    • io.aiven.kafka.connect.s3.source.utils.S3SourceRecord
    • io.aiven.kafka.connect.s3.source.utils.SourceRecordIterator (implements java.util.Iterator<E>)
    • 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