Add configuration in DebeziumMongoDbSourceTester

datastax · Jul 2, 2024 · 490108f · 490108f
1 parent 4776f92
commit 490108f
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/.../org/apache/pulsar/tests/integration/io/sources/debezium/DebeziumMongoDbSourceTester.java b/.../org/apache/pulsar/tests/integration/io/sources/debezium/DebeziumMongoDbSourceTester.java
@@ -42,12 +42,13 @@ public DebeziumMongoDbSourceTester(PulsarCluster cluster) {
         this.pulsarCluster = cluster;
         pulsarServiceUrl = "pulsar://pulsar-proxy:" + PulsarContainer.BROKER_PORT;
 
+        sourceConfig.put("connector.class", "io.debezium.connector.mongodb.MongoDbConnector");
         sourceConfig.put("mongodb.hosts", "rs0/" + DebeziumMongoDbContainer.NAME + ":27017");
         sourceConfig.put("mongodb.name", "dbserver1");
         sourceConfig.put("mongodb.user", "debezium");
         sourceConfig.put("mongodb.password", "dbz");
         sourceConfig.put("mongodb.task.id","1");
-        sourceConfig.put("database.include.list", "inventory");
+        sourceConfig.put("table.include.list", "inventory");
         sourceConfig.put("database.history.pulsar.service.url", pulsarServiceUrl);
         sourceConfig.put("topic.namespace", "debezium/mongodb");
         sourceConfig.put("capture.mode", "oplog");