This is an automated email from the ASF dual-hosted git repository.
lhotari pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new 827bc4f40a5 [improve][io] Set default connector class for debezium
connectors (#25215)
827bc4f40a5 is described below
commit 827bc4f40a5543dc83c6f42120a408ded6b2a983
Author: jiangpengcheng <[email protected]>
AuthorDate: Fri Feb 6 01:25:20 2026 +0800
[improve][io] Set default connector class for debezium connectors (#25215)
---
.../src/main/java/org/apache/pulsar/io/debezium/DebeziumSource.java | 1 +
.../integration/io/sources/debezium/DebeziumMongoDbSourceTester.java | 1 -
.../integration/io/sources/debezium/DebeziumMsSqlSourceTester.java | 1 -
.../integration/io/sources/debezium/DebeziumMySqlSourceTester.java | 1 -
.../integration/io/sources/debezium/DebeziumOracleDbSourceTester.java | 2 --
.../integration/io/sources/debezium/DebeziumPostgreSqlSourceTester.java | 1 -
6 files changed, 1 insertion(+), 6 deletions(-)
diff --git
a/pulsar-io/debezium/core/src/main/java/org/apache/pulsar/io/debezium/DebeziumSource.java
b/pulsar-io/debezium/core/src/main/java/org/apache/pulsar/io/debezium/DebeziumSource.java
index f0eaf2938d8..f5dc9d370de 100644
---
a/pulsar-io/debezium/core/src/main/java/org/apache/pulsar/io/debezium/DebeziumSource.java
+++
b/pulsar-io/debezium/core/src/main/java/org/apache/pulsar/io/debezium/DebeziumSource.java
@@ -81,6 +81,7 @@ public abstract class DebeziumSource extends
KafkaConnectSource {
@Override
public void open(Map<String, Object> config, SourceContext sourceContext)
throws Exception {
setDbConnectorTask(config);
+ setDbConnectorClass(config);
tryLoadingConfigSecret("database.user", config, sourceContext);
tryLoadingConfigSecret("database.password", config, sourceContext);
diff --git
a/tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/sources/debezium/DebeziumMongoDbSourceTester.java
b/tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/sources/debezium/DebeziumMongoDbSourceTester.java
index 1826d78f351..18655e6efeb 100644
---
a/tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/sources/debezium/DebeziumMongoDbSourceTester.java
+++
b/tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/sources/debezium/DebeziumMongoDbSourceTester.java
@@ -52,7 +52,6 @@ public class DebeziumMongoDbSourceTester extends
SourceTester<DebeziumMongoDbCon
sourceConfig.put("schema.history.internal.pulsar.service.url",
pulsarServiceUrl);
sourceConfig.put("topic.namespace", "debezium/mongodb");
sourceConfig.put("capture.mode", "change_streams_update_full");
- sourceConfig.put("connector.class",
"io.debezium.connector.mongodb.MongoDbConnector");
}
@Override
diff --git
a/tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/sources/debezium/DebeziumMsSqlSourceTester.java
b/tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/sources/debezium/DebeziumMsSqlSourceTester.java
index 2295a670660..f2ca3de9749 100644
---
a/tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/sources/debezium/DebeziumMsSqlSourceTester.java
+++
b/tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/sources/debezium/DebeziumMsSqlSourceTester.java
@@ -66,7 +66,6 @@ public class DebeziumMsSqlSourceTester extends
SourceTester<DebeziumMsSqlContain
sourceConfig.put("topic.prefix", "mssql");
sourceConfig.put("topic.namespace", "debezium/mssql");
sourceConfig.put("task.id", "1");
- sourceConfig.put("connector.class",
"io.debezium.connector.sqlserver.SqlServerConnector");
}
@Override
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 7f9ccbf5d20..590c3b6c308 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
@@ -67,7 +67,6 @@ public class DebeziumMySqlSourceTester extends
SourceTester<DebeziumMySQLContain
sourceConfig.put("value.converter", converterClassName);
sourceConfig.put("topic.namespace", "debezium/mysql-"
+ (converterClassName.endsWith("AvroConverter") ? "avro" :
"json"));
- sourceConfig.put("connector.class",
"io.debezium.connector.mysql.MySqlConnector");
}
@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 39b4361ee8a..09921d1ee1c 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
@@ -65,8 +65,6 @@ public class DebeziumOracleDbSourceTester extends
SourceTester<DebeziumOracleDbC
sourceConfig.put("schema.include.list", "inv");
sourceConfig.put("schema.history.internal.pulsar.service.url",
pulsarServiceUrl);
sourceConfig.put("topic.namespace", "debezium/oracle");
-
- sourceConfig.put("connector.class",
"io.debezium.connector.oracle.OracleConnector");
}
@Override
diff --git
a/tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/sources/debezium/DebeziumPostgreSqlSourceTester.java
b/tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/sources/debezium/DebeziumPostgreSqlSourceTester.java
index e23a5f1ad50..e8c5215513e 100644
---
a/tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/sources/debezium/DebeziumPostgreSqlSourceTester.java
+++
b/tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/sources/debezium/DebeziumPostgreSqlSourceTester.java
@@ -76,7 +76,6 @@ public class DebeziumPostgreSqlSourceTester extends
SourceTester<DebeziumPostgre
sourceConfig.put("table.exclude.list",
"inventory.spatial_ref_sys,inventory.geom");
sourceConfig.put("schema.history.internal.pulsar.service.url",
pulsarServiceUrl);
sourceConfig.put("topic.namespace", "debezium/postgresql");
- sourceConfig.put("connector.class",
"io.debezium.connector.postgresql.PostgresConnector");
}
@Override
