DBZ-777 Adjusting to changed SPI
This commit is contained in:
parent
796c0933b0
commit
85f00dd902
@ -16,6 +16,7 @@
|
||||
import io.debezium.connector.SnapshotRecord;
|
||||
import io.debezium.pipeline.spi.OffsetContext;
|
||||
import io.debezium.relational.TableId;
|
||||
import io.debezium.schema.DataCollectionId;
|
||||
|
||||
public class OracleOffsetContext implements OffsetContext {
|
||||
|
||||
@ -194,8 +195,8 @@ public void markLastSnapshotRecord() {
|
||||
}
|
||||
|
||||
@Override
|
||||
public void event(TableId tableId, Instant timestamp) {
|
||||
sourceInfo.setTableId(tableId);
|
||||
public void event(DataCollectionId tableId, Instant timestamp) {
|
||||
sourceInfo.setTableId((TableId) tableId);
|
||||
sourceInfo.setSourceTime(timestamp);
|
||||
}
|
||||
|
||||
|
Loading…
Reference in New Issue
Block a user