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

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

Related Packages

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

Class	Description
AbstractLookbackTest	Base class for Lookback test implementations.
Buffer<K extends Comparable<K>>	Lookback that uses a buffer to track the last N records.
BufferTest	Test for the Buffer Lookback implementation.
LastKey<K extends Comparable<K>>	A Lookback that only tracks the last key seen.
LastKeyTest	Test for LastKey Lookback implementation
Lookback<K extends Comparable<K>>	Defines the strategy for providing the next key for the client to search for.
None<K extends Comparable<K>>	Lookback that does not track any keys.
NoneTest	Test for None Lookback implementation.