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

DBZ-1245 Fix empty heartbeat message test

Browse Source
This commit is contained in:
Jiri Pechanec 2019-05-02 08:53:09 +02:00
parent b53f456912
commit 3b78e0bebb
1 changed files with 14 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
debezium-connector-postgres/src/test/java/io/debezium/connector/postgresql/RecordsStreamProducerIT.java
View File

@ -1281,11 +1281,22 @@ public void testEmptyChangesProducesHeartbeat() throws Exception {
.with(Heartbeat.HEARTBEAT_INTERVAL, "1")
.build());
setupRecordsProducer(config);
String statement = "CREATE SCHEMA s1;" ;
// Expecting one empty DDL change
consumer = testConsumer(1);
// Expecting 1 heartbeat + 1 data change
consumer = testConsumer(1 + 1);
recordsProducer.start(consumer, blackHole);
executeAndWait(
"DROP TABLE IF EXISTS test_table;" +
"CREATE TABLE test_table (id SERIAL, text TEXT);" +
"INSERT INTO test_table (text) VALUES ('mydata');"
);
consumer.clear();
consumer.expects(1);
// Expecting one empty DDL change
String statement = "CREATE SCHEMA s1;";
executeAndWait(statement);
// Expecting one heartbeat for the empty DDL change