Updated configs for upgraded debezium version

datastax · May 30, 2024 · aaac308 · aaac308
1 parent f22786d
commit aaac308
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/...org/apache/pulsar/tests/integration/io/sources/debezium/DebeziumOracleDbSourceTester.java b/...org/apache/pulsar/tests/integration/io/sources/debezium/DebeziumOracleDbSourceTester.java
@@ -62,10 +62,12 @@ public DebeziumOracleDbSourceTester(PulsarCluster cluster) {
         sourceConfig.put("database.password", "dbz");
         sourceConfig.put("database.server.name", "XE");
         sourceConfig.put("database.dbname", "XE");
+        sourceConfig.put("topic.prefix", "XE");
         sourceConfig.put("snapshot.mode", "schema_only");
 
         sourceConfig.put("schema.include.list", "inv");
-        sourceConfig.put("database.history.pulsar.service.url", pulsarServiceUrl);
+        sourceConfig.put("schema.history.internal", "org.apache.pulsar.io.debezium.oracle.PulsarDatabaseHistory");
+        sourceConfig.put("schema.history.internal.pulsar.service.url", pulsarServiceUrl);
         sourceConfig.put("topic.namespace", "debezium/oracle");
     }