From 7d24674c7414a265143eede9b5a12d1d863dfaec Mon Sep 17 00:00:00 2001 From: mukesh-ctds Date: Fri, 26 Jul 2024 09:56:14 +0530 Subject: [PATCH] Final update to configs --- .../io/sources/debezium/DebeziumMySqlSourceTester.java | 3 ++- .../io/sources/debezium/DebeziumOracleDbSourceTester.java | 4 ++-- .../io/sources/debezium/PulsarDebeziumOracleSourceTest.java | 2 +- 3 files changed, 5 insertions(+), 4 deletions(-) diff --git a/tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/sources/debezium/DebeziumMySqlSourceTester.java b/tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/sources/debezium/DebeziumMySqlSourceTester.java index 82344e0fc46af..6c16054dbfe8c 100644 --- a/tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/sources/debezium/DebeziumMySqlSourceTester.java +++ b/tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/sources/debezium/DebeziumMySqlSourceTester.java @@ -62,7 +62,9 @@ public DebeziumMySqlSourceTester(PulsarCluster cluster, String converterClassNam sourceConfig.put("database.password", "dbz"); sourceConfig.put("database.server.id", "184054"); sourceConfig.put("database.server.name", "dbserver1"); + sourceConfig.put("database.whitelist", "inventory"); sourceConfig.put("database.include.list", "inventory"); + sourceConfig.put("topic.prefix", "dbserver1"); if (!testWithClientBuilder) { sourceConfig.put("schema.history.internal.pulsar.service.url", pulsarServiceUrl); } @@ -70,7 +72,6 @@ public DebeziumMySqlSourceTester(PulsarCluster cluster, String converterClassNam sourceConfig.put("value.converter", converterClassName); sourceConfig.put("topic.namespace", "debezium/mysql-" + (converterClassName.endsWith("AvroConverter") ? "avro" : "json")); - sourceConfig.put("topic.prefix", "dbserver1"); } @Override diff --git a/tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/sources/debezium/DebeziumOracleDbSourceTester.java b/tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/sources/debezium/DebeziumOracleDbSourceTester.java index 39e26ce5d7045..dec55048a6230 100644 --- a/tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/sources/debezium/DebeziumOracleDbSourceTester.java +++ b/tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/sources/debezium/DebeziumOracleDbSourceTester.java @@ -52,7 +52,7 @@ public DebeziumOracleDbSourceTester(PulsarCluster cluster) { super(NAME); this.pulsarCluster = cluster; this.numEntriesToInsert = 1; - this.numEntriesExpectAfterStart = 1; + this.numEntriesExpectAfterStart = 0; pulsarServiceUrl = "pulsar://pulsar-proxy:" + PulsarContainer.BROKER_PORT; @@ -63,7 +63,7 @@ public DebeziumOracleDbSourceTester(PulsarCluster cluster) { sourceConfig.put("database.password", "dbz"); sourceConfig.put("database.server.name", "XE"); sourceConfig.put("database.dbname", "XE"); - sourceConfig.put("database.whitelist", "inv"); + sourceConfig.put("snapshot.mode", "schema_only"); sourceConfig.put("schema.include.list", "inv"); sourceConfig.put("schema.history.internal.pulsar.service.url", pulsarServiceUrl); sourceConfig.put("topic.namespace", "debezium/oracle"); diff --git a/tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/sources/debezium/PulsarDebeziumOracleSourceTest.java b/tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/sources/debezium/PulsarDebeziumOracleSourceTest.java index ffece0878b75b..1da0c1243972a 100644 --- a/tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/sources/debezium/PulsarDebeziumOracleSourceTest.java +++ b/tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/sources/debezium/PulsarDebeziumOracleSourceTest.java @@ -56,7 +56,7 @@ private void testDebeziumOracleDbConnect(String converterClassName, boolean json final String sourceName = "test-source-debezium-oracle-" + functionRuntimeType + "-" + randomName(8); // This is the event count to be created by prepareSource. - final int numMessages = 39; + final int numMessages = 1; @Cleanup PulsarClient client = PulsarClient.builder()