Uses of Class
io.aiven.commons.kafka.connector.source.OffsetManager
Packages that use OffsetManager
-
Uses of OffsetManager in io.aiven.commons.kafka.connector.source
Methods in io.aiven.commons.kafka.connector.source with parameters of type OffsetManagerModifier and TypeMethodDescriptionprotected abstract SourceCommonConfigAbstractSourceTask.configure(Map<String, String> props, OffsetManager offsetManager) Called byAbstractSourceTask.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.SourceRecordEvolvingSourceRecord.getSourceRecord(org.apache.kafka.connect.runtime.errors.ToleranceType tolerance, OffsetManager offsetManager) Creates a SourceRecord that can be returned to a Kafka topicConstructors in io.aiven.commons.kafka.connector.source with parameters of type OffsetManagerModifierConstructorDescriptionprotectedNativeSourceData(SourceCommonConfig sourceConfig, OffsetManager offsetManager) Constructor