From 4d18c708340b8e12da7f1beb48b694b9b3b30cfa Mon Sep 17 00:00:00 2001 From: Jiri Pechanec Date: Thu, 15 Aug 2019 12:59:29 +0200 Subject: [PATCH] DBZ-777 Make sure the empty events are generated while streaming --- .../debezium/connector/postgresql/RecordsStreamProducerIT.java | 1 + 1 file changed, 1 insertion(+) diff --git 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 index 73252afc3..c0f987628 100644 --- 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));" +