Uses of Class
io.aiven.commons.kafka.connector.source.OffsetManager

Packages that use OffsetManager

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

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

Modifier and Type	Method	Description
protected abstract SourceCommonConfig	AbstractSourceTask.configure(Map<String,String> props, OffsetManager offsetManager)	Called by AbstractSourceTask.start(java.util.Map<java.lang.String, java.lang.String>) to allows the concrete implementation to configure itself based on properties.
org.apache.kafka.connect.source.SourceRecord	EvolvingSourceRecord.getSourceRecord(org.apache.kafka.connect.runtime.errors.ToleranceType tolerance, OffsetManager offsetManager)	Creates a SourceRecord that can be returned to a Kafka topic

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

Modifier	Constructor	Description
protected	NativeSourceData(SourceCommonConfig sourceConfig, OffsetManager offsetManager)	Constructor

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

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

Modifier and Type	Method	Description
protected SourceCommonConfig	ExampleSourceTask.configure(Map<String,String> props, OffsetManager offsetManager)

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

Modifier	Constructor	Description
	ExampleNativeSourceData(SourceCommonConfig sourceConfig, OffsetManager offsetManager)	Constructor.

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

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

Modifier	Constructor	Description
	ExampleCsvSourceData(SourceCommonConfig sourceConfig, OffsetManager offsetManager)	Constructor.