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

DBZ-5940 Verify server is configured with properties

Browse Source
This commit is contained in:
Jeremy Ford 2022-12-15 09:16:44 -05:00 committed by Jiri Pechanec
parent 0809bc356b
commit ca17a63270
2 changed files with 16 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
debezium-server/debezium-server-core/src/test/java/io/debezium/server/DebeziumServerTest.java
View File

@ -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

4
debezium-server/debezium-server-core/src/test/java/io/debezium/server/TestConfigSource.java
View File

@ -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");