- All Superinterfaces:
- io.debezium.engine.DebeziumEngine.ChangeConsumer<org.apache.kafka.connect.source.SourceRecord>
- Enclosing class:
- EmbeddedEngine
Deprecated.
@Deprecated
public static interface EmbeddedEngine.ChangeConsumer
extends io.debezium.engine.DebeziumEngine.ChangeConsumer<org.apache.kafka.connect.source.SourceRecord>
A contract invoked by the embedded engine when it has received a batch of change records to be processed. Allows
to process multiple records in one go, acknowledging their processing once that's done.