Package io.aiven.kafka.connect.common.source
package io.aiven.kafka.connect.common.source
-
ClassDescriptionThis 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 successive
AbstractSourceTask.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.OffsetManager<E extends OffsetManager.OffsetManagerEntry<E>>The definition of an entry in the OffsetManager.The OffsetManager Key.