Uses of Package
io.aiven.commons.kafka.connector.source

Packages that use io.aiven.commons.kafka.connector.source

Package	Description
io.aiven.commons.kafka.connector.source
io.aiven.commons.kafka.connector.source.extractor
io.aiven.commons.kafka.connector.source.impl	This package contains simple example implementations of the generic objects for EvolvingSourceRecord and EvolvingSourceRecordIterator.
io.aiven.commons.kafka.connector.source.impl.csv

Classes in io.aiven.commons.kafka.connector.source used by io.aiven.commons.kafka.connector.source

Class	Description
AbstractSourceNativeInfo	An abstract implementation of NativeInfo handling for Source.
EvolvingSourceRecord	An evolving source record initially retrieved from the storage layer.
EvolvingSourceRecordIterator	Iterator that processes Native Source Data and creates AbstractSourceRecords.
NativeSourceData	A data source for native info from a source.
NativeSourceData.KeySerde	A serializer / deserializer pair for a native key.
OffsetManager	An offset manager that handles local updates to Kafka offset manager.
OffsetManager.OffsetManagerEntry	The definition of an entry in the OffsetManager.
OffsetManager.OffsetManagerKey	The OffsetManager Key.

Classes in io.aiven.commons.kafka.connector.source used by io.aiven.commons.kafka.connector.source.extractor

Class	Description
AbstractSourceNativeInfo	An abstract implementation of NativeInfo handling for Source.
EvolvingSourceRecord	An evolving source record initially retrieved from the storage layer.

Classes in io.aiven.commons.kafka.connector.source used by io.aiven.commons.kafka.connector.source.impl

Class	Description
AbstractSourceNativeInfo	An abstract implementation of NativeInfo handling for Source.
AbstractSourceTask	This class handles extracting records from an iterator and returning them to Kafka.
EvolvingSourceRecordIterator	Iterator that processes Native Source Data and creates AbstractSourceRecords.
NativeSourceData	A data source for native info from a source.
NativeSourceData.KeySerde	A serializer / deserializer pair for a native key.
OffsetManager	An offset manager that handles local updates to Kafka offset manager.
OffsetManager.OffsetManagerEntry	The definition of an entry in the OffsetManager.
OffsetManager.OffsetManagerKey	The OffsetManager Key.

Classes in io.aiven.commons.kafka.connector.source used by io.aiven.commons.kafka.connector.source.impl.csv

Class	Description
AbstractSourceNativeInfo	An abstract implementation of NativeInfo handling for Source.
NativeSourceData	A data source for native info from a source.
NativeSourceData.KeySerde	A serializer / deserializer pair for a native key.
OffsetManager	An offset manager that handles local updates to Kafka offset manager.
OffsetManager.OffsetManagerEntry	The definition of an entry in the OffsetManager.
OffsetManager.OffsetManagerKey	The OffsetManager Key.