Class Hierarchy
- java.lang.Object
- 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.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)
- org.apache.commons.lang3.time.StopWatch
- org.apache.commons.collections4.collection.SynchronizedCollection<E> (implements java.util.Collection<E>, java.io.Serializable)
- org.apache.commons.collections4.queue.SynchronizedQueue<E> (implements java.util.Queue<E>)
- io.aiven.kafka.connect.common.source.RingBuffer<K>