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

DBZ-5014 Uncomment validations

Browse Source
This commit is contained in:
Cesar Martinez 2022-05-06 10:24:26 -05:00 committed by Jiri Pechanec
parent 72e51e02c7
commit c0ac30593c
1 changed files with 6 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
debezium-connector-postgres/src/test/java/io/debezium/connector/postgresql/RecordsStreamProducerIT.java
View File

@ -71,7 +71,6 @@
import io.debezium.data.Enum;
import io.debezium.data.Envelope;
import io.debezium.data.Envelope.FieldName;
import io.debezium.data.Envelope.Operation;
import io.debezium.data.SpecialValueDecimal;
import io.debezium.data.VariableScaleDecimal;
import io.debezium.data.VerifyRecord;
@ -2932,12 +2931,12 @@ private SourceRecord assertRecordDeleted(String expectedTopicName, String pkColu
private SourceRecord assertRecordDeleted(SourceRecord deletedRecord, String expectedTopicName, String pkColumn, Integer pk) throws InterruptedException {
assertEquals(topicName(expectedTopicName), deletedRecord.topic());
// if (pk != null) {
// VerifyRecord.isValidDelete(deletedRecord, pkColumn, pk);
// }
// else {
// VerifyRecord.isValidDelete(deletedRecord);
// }
if (pk != null) {
VerifyRecord.isValidDelete(deletedRecord, pkColumn, pk);
}
else {
VerifyRecord.isValidDelete(deletedRecord);
}
return deletedRecord;
}