Uses of Class io.aiven.commons.kafka.connector.source.OffsetManager (Aiven framework for connectors on Apache Kafka 0.3.0-SNAPSHOT API)

Packages that use OffsetManager

Package

Description

io.aiven.commons.kafka.connector.source

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