DBZ-2468 Fix test failure - PostgresConnectorIT#shouldExecuteOnConnectStatements
This commit is contained in:
parent
c4d1772aee
commit
bb0b3fd158
@ -601,6 +601,7 @@ public void shouldExecuteOnConnectStatements() throws Exception {
|
|||||||
.with(PostgresConnectorConfig.DROP_SLOT_ON_STOP, Boolean.FALSE);
|
.with(PostgresConnectorConfig.DROP_SLOT_ON_STOP, Boolean.FALSE);
|
||||||
start(PostgresConnector.class, configBuilder.build());
|
start(PostgresConnector.class, configBuilder.build());
|
||||||
assertConnectorIsRunning();
|
assertConnectorIsRunning();
|
||||||
|
waitForStreamingRunning();
|
||||||
|
|
||||||
SourceRecords actualRecords = consumeRecordsByTopic(6);
|
SourceRecords actualRecords = consumeRecordsByTopic(6);
|
||||||
assertKey(actualRecords.allRecordsInOrder().get(0), "pk", 1);
|
assertKey(actualRecords.allRecordsInOrder().get(0), "pk", 1);
|
||||||
|
Loading…
Reference in New Issue
Block a user