From 3e1bb6cbef6fcab024b4d9e360d4ec9243b56fd4 Mon Sep 17 00:00:00 2001 From: Jiri Pechanec Date: Tue, 6 Aug 2024 08:59:28 +0200 Subject: [PATCH] DBZ-8123 Process compression notification messages --- .../transforms/timescaledb/TimescaleDbDatabaseTest.java | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/debezium-connector-postgres/src/test/java/io/debezium/connector/postgresql/transforms/timescaledb/TimescaleDbDatabaseTest.java b/debezium-connector-postgres/src/test/java/io/debezium/connector/postgresql/transforms/timescaledb/TimescaleDbDatabaseTest.java index 58abce5ac..4fa989fcd 100644 --- a/debezium-connector-postgres/src/test/java/io/debezium/connector/postgresql/transforms/timescaledb/TimescaleDbDatabaseTest.java +++ b/debezium-connector-postgres/src/test/java/io/debezium/connector/postgresql/transforms/timescaledb/TimescaleDbDatabaseTest.java @@ -27,6 +27,7 @@ import io.debezium.embedded.AbstractConnectorTest; import io.debezium.jdbc.JdbcConfiguration; import io.debezium.testing.testcontainers.ImageNames; +import io.debezium.util.Testing; public class TimescaleDbDatabaseTest extends AbstractConnectorTest { @@ -145,7 +146,7 @@ public void shouldTransformAggregates() throws Exception { @Test public void shouldTransformCompressedChunks() throws Exception { - // Testing.Print.enable(); + Testing.Print.enable(); start(PostgresConnector.class, config); waitForStreamingRunning("postgres", TestHelper.TEST_SERVER); @@ -155,7 +156,8 @@ public void shouldTransformCompressedChunks() throws Exception { "ALTER TABLE conditions SET (timescaledb.compress, timescaledb.compress_orderby = 'time DESC', timescaledb.compress_segmentby = 'location')", "SELECT compress_chunk('_timescaledb_internal._hyper_1_1_chunk')"); - var records = consumeRecordsByTopic(4); + // 3 data messages, 1 raw compressed chunk message, 2 WAL notification messages about compression in progress + var records = consumeRecordsByTopic(6); assertConnectorIsRunning(); assertThat(records.recordsForTopic("timescaledb.public.conditions")).hasSize(3);