From ca17a63270a292826fa2af58f609fe8039e96d84 Mon Sep 17 00:00:00 2001 From: Jeremy Ford Date: Thu, 15 Dec 2022 09:16:44 -0500 Subject: [PATCH] DBZ-5940 Verify server is configured with properties --- .../java/io/debezium/server/DebeziumServerTest.java | 12 ++++++++++++ .../java/io/debezium/server/TestConfigSource.java | 4 ++++ 2 files changed, 16 insertions(+) diff --git a/debezium-server/debezium-server-core/src/test/java/io/debezium/server/DebeziumServerTest.java b/debezium-server/debezium-server-core/src/test/java/io/debezium/server/DebeziumServerTest.java index 6b541a43a..8ee78eb95 100644 --- a/debezium-server/debezium-server-core/src/test/java/io/debezium/server/DebeziumServerTest.java +++ b/debezium-server/debezium-server-core/src/test/java/io/debezium/server/DebeziumServerTest.java @@ -64,6 +64,18 @@ public void testProps() { assertThat(properties.getProperty("database.allowPublicKeyRetrieval")).isNotNull(); assertThat(properties.getProperty("database.allowPublicKeyRetrieval")).isEqualTo("true"); + + assertThat(properties.getProperty("transforms.hoist.predicate")).isNotNull(); + assertThat(properties.getProperty("transforms.hoist.predicate")).isEqualTo("topicNameMatch"); + + assertThat(properties.getProperty("predicates")).isNotNull(); + assertThat(properties.getProperty("predicates")).isEqualTo("topicNameMatch"); + + assertThat(properties.getProperty("predicates.topicNameMatch.type")).isNotNull(); + assertThat(properties.getProperty("predicates.topicNameMatch.type")).isEqualTo("org.apache.kafka.connect.transforms.predicates.TopicNameMatches"); + + assertThat(properties.getProperty("predicates.topicNameMatch.pattern")).isNotNull(); + assertThat(properties.getProperty("predicates.topicNameMatch.pattern")).isEqualTo(".*"); } @Test diff --git a/debezium-server/debezium-server-core/src/test/java/io/debezium/server/TestConfigSource.java b/debezium-server/debezium-server-core/src/test/java/io/debezium/server/TestConfigSource.java index aba3d578e..ac93a3bbd 100644 --- a/debezium-server/debezium-server-core/src/test/java/io/debezium/server/TestConfigSource.java +++ b/debezium-server/debezium-server-core/src/test/java/io/debezium/server/TestConfigSource.java @@ -66,6 +66,10 @@ public TestConfigSource() { unitTest.put("debezium.transforms", "hoist"); unitTest.put("debezium.transforms.hoist.type", "org.apache.kafka.connect.transforms.HoistField$Value"); unitTest.put("debezium.transforms.hoist.field", "line"); + unitTest.put("debezium.transforms.hoist.predicate", "topicNameMatch"); + unitTest.put("debezium.predicates", "topicNameMatch"); + unitTest.put("debezium.predicates.topicNameMatch.type", "org.apache.kafka.connect.transforms.predicates.TopicNameMatches"); + unitTest.put("debezium.predicates.topicNameMatch.pattern", ".*"); // DBZ-2622 For testing properties passed via smallrye/microprofile environment variables unitTest.put("DEBEZIUM_SOURCE_TABLE_INCLUDE_LIST", "public.table_name");