Final update to configs

datastax · Jul 26, 2024 · 7d24674 · 7d24674
1 parent 6187d54
commit 7d24674
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 4 deletions.
diff --git a/...va/org/apache/pulsar/tests/integration/io/sources/debezium/DebeziumMySqlSourceTester.java b/...va/org/apache/pulsar/tests/integration/io/sources/debezium/DebeziumMySqlSourceTester.java
@@ -62,15 +62,16 @@ 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);
         }
         sourceConfig.put("key.converter", converterClassName);
         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/...org/apache/pulsar/tests/integration/io/sources/debezium/DebeziumOracleDbSourceTester.java b/...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/...g/apache/pulsar/tests/integration/io/sources/debezium/PulsarDebeziumOracleSourceTest.java b/...g/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()