dcb6b04835
Added Offsets contract in DebeziumEngine and implemented it as SourceRecordOffsets in EmbeddedEngine. Added additional method buildOffsets in RecordCommitter for retrieving an Offsets object, implemented in ConvertingEngineBuilder and EmbeddedEngine. Modified markProcessed method to use Offsets contract. Updated tests and documentation. |
||
---|---|---|
.. | ||
src | ||
pom.xml |