Package io.aiven.commons.kafka.connector.source
package io.aiven.commons.kafka.connector.source
-
ClassDescriptionAn abstract implementation of NativeInfo handling for Source.This class handles extracting records from an iterator and returning them to Kafka.An evolving source record initially retrieved from the storage layer.Iterator that processes Native Source Data and creates AbstractSourceRecords.NativeSourceData<K extends Comparable<K>>A data source for native info from a source.A serializer / deserializer pair for a native key.An offset manager that handles local updates to Kafka offset manager.The definition of an entry in the OffsetManager.The OffsetManager Key.