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

Packages that use OffsetManager.OffsetManagerKey

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

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

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

Modifier and Type	Method	Description
OffsetManager.OffsetManagerKey	OffsetManager.OffsetManagerEntry.getManagerKey()	Gets the OffsetManagerKey for this entry.
protected abstract OffsetManager.OffsetManagerKey	NativeSourceData.getOffsetManagerKey(K nativeKey)	Creates an offset manager key for the native key.

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

Modifier and Type	Method	Description
Optional<Map<String,Object>>	OffsetManager.getEntryData(OffsetManager.OffsetManagerKey key)	Get entry data from the offset manager.
void	OffsetManager.removeEntry(OffsetManager.OffsetManagerKey key)	Removes the specified entry from the in memory table.

Method parameters in io.aiven.commons.kafka.connector.source with type arguments of type OffsetManager.OffsetManagerKey

Modifier and Type	Method	Description
void	OffsetManager.populateOffsetManager(Collection<OffsetManager.OffsetManagerKey> offsetManagerKeys)	Gets any offset information stored in the offsetStorageReader and adds to the local offsets Map.