Uses of Interface
io.aiven.commons.kafka.connector.source.OffsetManager.OffsetManagerEntry
Packages that use OffsetManager.OffsetManagerEntry
-
Uses of OffsetManager.OffsetManagerEntry in io.aiven.commons.kafka.connector.source
Methods in io.aiven.commons.kafka.connector.source that return OffsetManager.OffsetManagerEntryModifier and TypeMethodDescriptionprotected abstract OffsetManager.OffsetManagerEntryNativeSourceData.createOffsetManagerEntry(Context context) Creates an offset manager entry from a context.abstract OffsetManager.OffsetManagerEntryNativeSourceData.createOffsetManagerEntry(Map<String, Object> data) Creates an offset manager entry using the data in the map.OffsetManager.OffsetManagerEntry.fromProperties(Map<String, Object> properties) Creates a new OffsetManagerEntry by wrapping the properties with the current implementation.EvolvingSourceRecord.getOffsetManagerEntry()Gets the offset manager entry for this source record.Methods in io.aiven.commons.kafka.connector.source with parameters of type OffsetManager.OffsetManagerEntryModifier and TypeMethodDescriptionvoidOffsetManager.addEntry(OffsetManager.OffsetManagerEntry entry) Get add an entry to the offset manager.voidEvolvingSourceRecord.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.OffsetManagerEntryModifierConstructorDescriptionEvolvingSourceRecord(AbstractSourceNativeInfo<?, ?> sourceNativeInfo, OffsetManager.OffsetManagerEntry offsetManagerEntry, Context context) Construct a source record from a native item.