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

DBZ-1024 Return test assert

Browse Source
This commit is contained in:
Jiri Pechanec 2018-12-07 10:41:42 +01:00 committed by Gunnar Morling
parent 0b78f0c31a
commit ea5c8512b7
1 changed files with 1 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
debezium-connector-postgres/src/test/java/io/debezium/connector/postgresql/AbstractRecordsProducerTest.java
View File

@ -633,6 +633,7 @@ protected void assertRecordOffsetAndSnapshotSource(SourceRecord record, boolean
final Boolean sourceLastSnapshotRecord = source.getBoolean(SourceInfo.LAST_SNAPSHOT_RECORD_KEY); final Boolean sourceLastSnapshotRecord = source.getBoolean(SourceInfo.LAST_SNAPSHOT_RECORD_KEY);
if (expectSnapshot) { if (expectSnapshot) {
Assert.assertTrue("Snapshot marker expected in source but not found", sourceSnapshot); Assert.assertTrue("Snapshot marker expected in source but not found", sourceSnapshot);
assertEquals("Last snapshot record marker in source mismatch", expectedLastSnapshotRecord, sourceLastSnapshotRecord);
} }
else { else {
assertNull("Source snapshot marker not expected, but found", sourceSnapshot); assertNull("Source snapshot marker not expected, but found", sourceSnapshot);