@ThreadSafe @Deprecated public static interface EmbeddedEngine.RecordCommitter extends io.debezium.engine.DebeziumEngine.RecordCommitter<org.apache.kafka.connect.source.SourceRecord>
EmbeddedEngine.ChangeConsumer
s, allowing them to commit single records as they have been processed
and to signal that offsets may be flushed eventually.Copyright © 2020. All rights reserved.