Updated db2 source config

apache · Mar 17, 2023 · c0a203d · c0a203d
1 parent f722914
commit c0a203d
Showing 1 changed file with 6 additions and 4 deletions.
diff --git a/...va/org/apache/pulsar/tests/integration/io/sources/debezium/DebeziumDB2DbSourceTester.java b/...va/org/apache/pulsar/tests/integration/io/sources/debezium/DebeziumDB2DbSourceTester.java
@@ -54,16 +54,18 @@ public DebeziumDB2DbSourceTester(PulsarCluster cluster) {
         this.numEntriesExpectAfterStart = 0;
 
         pulsarServiceUrl = "pulsar://pulsar-proxy:" + PulsarContainer.BROKER_PORT;
-
+        sourceConfig.put("connector.class", "io.debezium.connector.db2.Db2Connector");
         sourceConfig.put("database.hostname", DebeziumDB2DbContainer.NAME);
         sourceConfig.put("database.port", "50000");
         sourceConfig.put("database.user", "db2inst1");
         sourceConfig.put("database.password", "admin");
-        //sourceConfig.put("database.server.name", "XE");
         sourceConfig.put("database.dbname", "mydb2");
-        sourceConfig.put("snapshot.mode", "schema_only");  //??
+        sourceConfig.put("topic.prefix", "stores");
+        sourceConfig.put("table.include.list", "DB2INST1.STORES");
+
+        //sourceConfig.put("snapshot.mode", "schema_only");  //??
 
-        sourceConfig.put("schema.include.list", "inv"); //??
+        //sourceConfig.put("schema.include.list", "inv"); //??
         sourceConfig.put("database.history.pulsar.service.url", pulsarServiceUrl);
         sourceConfig.put("topic.namespace", "debezium/db2");
     }