Package io.aiven.kafka.connect.common.source
package io.aiven.kafka.connect.common.source
-
ClassDescriptionAbstractSourceRecord<K extends Comparable<K>,
N, O extends OffsetManager.OffsetManagerEntry<O>, E extends AbstractSourceRecord<K, N, O, E>> An abstract source record as retrieved from the storage layer.AbstractSourceRecordIterator<N,K extends Comparable<K>, O extends OffsetManager.OffsetManagerEntry<O>, T extends AbstractSourceRecord<K, N, O, T>> Iterator that processes cloud storage items and creates Kafka source records.This class handles extracting records from an iterator and returning them to Kafka.A functional interface that will abort the timer.Performs a delay based on the number of successiveAbstractSourceTask.Backoff.delay()orAbstractSourceTask.Backoff.cleanDelay()calls without aAbstractSourceTask.Backoff.reset().An interface to define the Backoff configuration.A functional interface to return long values.Calculates elapsed time and flags when expired.NativeSourceData<K extends Comparable<K>,N, O extends OffsetManager.OffsetManagerEntry<O>, T extends AbstractSourceRecord<K, N, O, T>> OffsetManager<E extends OffsetManager.OffsetManagerEntry<E>>The definition of an entry in the OffsetManager.The OffsetManager Key.RingBuffer<K>Implements a ring buffer of items.