Package io.aiven.commons.kafka.connector.source.impl

package io.aiven.commons.kafka.connector.source.impl

This package contains simple example implementations of the generic objects for EvolvingSourceRecord and EvolvingSourceRecordIterator. These objects are using in the tests that verify the Abstract implementations.

Related Packages

Package	Description
io.aiven.commons.kafka.connector.source
io.aiven.commons.kafka.connector.source.impl.csv
io.aiven.commons.kafka.connector.source.impl.nativeProvided	Implementations of items provided by an external storage layer.
io.aiven.commons.kafka.connector.source.config
io.aiven.commons.kafka.connector.source.extractor
io.aiven.commons.kafka.connector.source.lookback
io.aiven.commons.kafka.connector.source.task

Classes

Class	Description
ExampleNativeSourceData	An actual NativeSourceData implementation would use a NativeClient to retrieve the NativeItems.
ExampleOffsetManagerEntry	An implementation of OffsetManagerEntry.
ExampleSourceNativeInfo	This example data object has a String key and a byte buffer as its data object.
ExampleSourceTask	An example implementation of the Source task.