diff --git a/pom.xml b/pom.xml index 49f2fb06338d2..2aa08a469a8c5 100644 --- a/pom.xml +++ b/pom.xml @@ -164,7 +164,7 @@ flexible messaging model and an intuitive client API. 334 2.13 2.13.10 - 2.6.2.Final + 2.5.4.Final 42.5.0 8.0.30 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 2554f3cef6f50..40078d67365ca 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 @@ -56,19 +56,16 @@ public DebeziumOracleDbSourceTester(PulsarCluster cluster) { pulsarServiceUrl = "pulsar://pulsar-proxy:" + PulsarContainer.BROKER_PORT; - sourceConfig.put("connector.class", "io.debezium.connector.oracle.OracleConnector"); sourceConfig.put("database.hostname", DebeziumOracleDbContainer.NAME); sourceConfig.put("database.port", "1521"); sourceConfig.put("database.user", "dbzuser"); sourceConfig.put("database.password", "dbz"); sourceConfig.put("database.server.name", "XE"); sourceConfig.put("database.dbname", "XE"); - sourceConfig.put("topic.prefix", "topic"); sourceConfig.put("snapshot.mode", "schema_only"); sourceConfig.put("schema.include.list", "inv"); - sourceConfig.put("schema.history.internal", "org.apache.pulsar.io.debezium.oracle.PulsarDatabaseHistory"); - sourceConfig.put("schema.history.internal.pulsar.service.url", pulsarServiceUrl); + sourceConfig.put("database.history.pulsar.service.url", pulsarServiceUrl); sourceConfig.put("topic.namespace", "debezium/oracle"); }