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

DBZ-2319 Fix test failure - PostgresConnectorIT#shouldOutputRecordsInCloudEventsFormat

Browse Source
This commit is contained in:
Chris Cranford 2020-07-08 16:08:05 -04:00 committed by Jiri Pechanec
parent 5affa8cbab
commit 0e5122c69d
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
debezium-connector-postgres/src/test/java/io/debezium/connector/postgresql/PostgresConnectorIT.java
View File

@ -1625,6 +1625,7 @@ public void shouldOutputRecordsInCloudEventsFormat() throws Exception {
start(PostgresConnector.class, configBuilder.build());
assertConnectorIsRunning();
waitForSnapshotToBeCompleted();
SourceRecords snapshotRecords = consumeRecordsByTopic(2);
List<SourceRecord> snapshot = snapshotRecords.allRecordsInOrder();
@ -1636,6 +1637,7 @@ public void shouldOutputRecordsInCloudEventsFormat() throws Exception {
}
// insert some more records and test streaming
waitForStreamingRunning();
TestHelper.execute(INSERT_STMT);
Testing.Print.enable();