Class Hierarchy
- java.lang.Object
- io.aiven.kafka.connect.common.source.AbstractSourceRecord<K,
N, O, T> - io.aiven.kafka.connect.common.source.AbstractSourceRecordIterator<K,
N, O, T> (implements java.util.Iterator<E>) - io.aiven.kafka.connect.common.source.AbstractSourceTask.Backoff
- io.aiven.kafka.connect.common.source.OffsetManager<E>
- org.apache.kafka.connect.source.SourceTask (implements org.apache.kafka.connect.connector.Task)
- io.aiven.kafka.connect.common.source.AbstractSourceTask
- org.apache.commons.lang3.time.StopWatch
- io.aiven.kafka.connect.common.source.AbstractSourceTask.Timer
- io.aiven.kafka.connect.common.source.AbstractSourceRecord<K,
Interface Hierarchy
- io.aiven.kafka.connect.common.source.AbstractSourceTask.AbortTrigger
- io.aiven.kafka.connect.common.source.AbstractSourceTask.BackoffConfig
- io.aiven.kafka.connect.common.source.AbstractSourceTask.SupplierOfLong
- java.lang.Comparable<T>
- io.aiven.kafka.connect.common.source.OffsetManager.OffsetManagerEntry<T>
- io.aiven.kafka.connect.common.source.NativeSourceData<K,
N, O, T> - io.aiven.kafka.connect.common.source.OffsetManager.OffsetManagerKey