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

Packages that use OffsetManager.OffsetManagerEntry

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

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.