Uses of Interface
io.aiven.commons.kafka.connector.source.OffsetManager.OffsetManagerEntry

Packages that use OffsetManager.OffsetManagerEntry

Package	Description
io.aiven.commons.kafka.connector.source
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

Uses of OffsetManager.OffsetManagerEntry in io.aiven.commons.kafka.connector.source

Methods in io.aiven.commons.kafka.connector.source that return OffsetManager.OffsetManagerEntry

Modifier and Type	Method	Description
protected abstract OffsetManager.OffsetManagerEntry	NativeSourceData.createOffsetManagerEntry(Context context)	Creates an offset manager entry from a context.
abstract OffsetManager.OffsetManagerEntry	NativeSourceData.createOffsetManagerEntry(Map<String,Object> data)	Creates an offset manager entry using the data in the map.
OffsetManager.OffsetManagerEntry	OffsetManager.OffsetManagerEntry.fromProperties(Map<String,Object> properties)	Creates a new OffsetManagerEntry by wrapping the properties with the current implementation.
OffsetManager.OffsetManagerEntry	EvolvingSourceRecord.getOffsetManagerEntry()	Gets the offset manager entry for this source record.

Methods in io.aiven.commons.kafka.connector.source with parameters of type OffsetManager.OffsetManagerEntry

Modifier and Type	Method	Description
void	OffsetManager.addEntry(OffsetManager.OffsetManagerEntry entry)	Get add an entry to the offset manager.
void	EvolvingSourceRecord.setOffsetManagerEntry(OffsetManager.OffsetManagerEntry offsetManagerEntry)	Sets the offset manager entry for this source record.

Constructors in io.aiven.commons.kafka.connector.source with parameters of type OffsetManager.OffsetManagerEntry

Modifier	Constructor	Description
	EvolvingSourceRecord(AbstractSourceNativeInfo<?,?> sourceNativeInfo, OffsetManager.OffsetManagerEntry offsetManagerEntry, Context context)	Construct a source record from a native item.

Uses of OffsetManager.OffsetManagerEntry in io.aiven.commons.kafka.connector.source.impl

Classes in io.aiven.commons.kafka.connector.source.impl that implement OffsetManager.OffsetManagerEntry

Modifier and Type	Class	Description
class	ExampleOffsetManagerEntry	An implementation of OffsetManagerEntry.

Methods in io.aiven.commons.kafka.connector.source.impl that return OffsetManager.OffsetManagerEntry

Modifier and Type	Method	Description
protected OffsetManager.OffsetManagerEntry	ExampleNativeSourceData.createOffsetManagerEntry(Context context)
OffsetManager.OffsetManagerEntry	ExampleNativeSourceData.createOffsetManagerEntry(Map<String,Object> data)

Uses of OffsetManager.OffsetManagerEntry in io.aiven.commons.kafka.connector.source.impl.csv

Methods in io.aiven.commons.kafka.connector.source.impl.csv that return OffsetManager.OffsetManagerEntry

Modifier and Type	Method	Description
protected OffsetManager.OffsetManagerEntry	ExampleCsvSourceData.createOffsetManagerEntry(Context context)
OffsetManager.OffsetManagerEntry	ExampleCsvSourceData.createOffsetManagerEntry(Map<String,Object> data)