alexey.rassokhin/tet123
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

DBZ-1088 use correct key for update of PK insert event

Browse Source
This commit is contained in:
Jiri Pechanec 2019-01-17 13:48:12 +01:00 committed by Gunnar Morling
parent 1cf257478b
commit 25156730f0
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
debezium-core/src/main/java/io/debezium/relational/RelationalChangeRecordEmitter.java
View File

@ -100,7 +100,7 @@ private void emitUpdateRecord(Receiver receiver, TableSchema tableSchema)
receiver.changeRecord(tableSchema, Operation.DELETE, oldKey, envelope, offsetContext);
envelope = tableSchema.getEnvelopeSchema().create(newValue, offsetContext.getSourceInfo(), clock.currentTimeInMillis());
receiver.changeRecord(tableSchema, Operation.UPDATE, oldKey, envelope, offsetContext);
receiver.changeRecord(tableSchema, Operation.CREATE, newKey, envelope, offsetContext);
}
}