Skip to content

Commit 4688644

Browse files
committed
Update configs for upgraded debezium version
1 parent 1995591 commit 4688644

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/sources/debezium/DebeziumOracleDbSourceTester.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -54,13 +54,13 @@ public DebeziumOracleDbSourceTester(PulsarCluster cluster) {
5454

5555
pulsarServiceUrl = "pulsar://pulsar-proxy:" + PulsarContainer.BROKER_PORT;
5656

57+
sourceConfig.put("connector.class", "io.debezium.connector.oracle.OracleConnector");
5758
sourceConfig.put("database.hostname", DebeziumOracleDbContainer.NAME);
5859
sourceConfig.put("database.port", "1521");
5960
sourceConfig.put("database.user", "dbzuser");
6061
sourceConfig.put("database.password", "dbz");
6162
sourceConfig.put("database.server.name", "XE");
6263
sourceConfig.put("database.dbname", "XE");
63-
sourceConfig.put("topic.prefix", "XE");
6464
sourceConfig.put("snapshot.mode", "schema_only");
6565

6666
sourceConfig.put("schema.include.list", "inv");

0 commit comments

Comments
 (0)