DBZ-777 Make sure the empty events are generated while streaming

2019-08-15 12:59:29 +02:00 · 2019-08-15 12:59:29 +02:00 · 4d18c70834
commit 4d18c70834
parent 5ffe8123f1
1 changed files with 1 additions and 0 deletions
--- a/debezium-connector-postgres/src/test/java/io/debezium/connector/postgresql/RecordsStreamProducerIT.java
+++ b/debezium-connector-postgres/src/test/java/io/debezium/connector/postgresql/RecordsStreamProducerIT.java
@ -983,6 +983,7 @@ public void shouldReceiveHeartbeatAlsoWhenChangingNonWhitelistedTable() throws E
                .with(PostgresConnectorConfig.SNAPSHOT_MODE, SnapshotMode.NEVER),
                false
        );
+        waitForStreamingToStart();

        String statement = "CREATE SCHEMA s1;" +
                           "CREATE TABLE s1.a (pk SERIAL, aa integer, PRIMARY KEY(pk));" +