Uses of Interface
org.springframework.cloud.fn.common.cdc.EmbeddedEngine.RecordCommitter

Packages that use EmbeddedEngine.RecordCommitter

Package	Description
org.springframework.cloud.fn.common.cdc

Uses of EmbeddedEngine.RecordCommitter in org.springframework.cloud.fn.common.cdc

Methods in org.springframework.cloud.fn.common.cdc that return EmbeddedEngine.RecordCommitter

Modifier and Type	Method and Description
protected EmbeddedEngine.RecordCommitter	EmbeddedEngine.buildRecordCommitter(org.apache.kafka.connect.storage.OffsetStorageWriter offsetWriter, org.apache.kafka.connect.source.SourceTask task, Duration commitTimeout) Creates a new RecordCommitter that is responsible for informing the engine about the updates to the given batch