diff --git a/src/test/java/io/debezium/connector/db2/BlockingSnapshotIT.java b/src/test/java/io/debezium/connector/db2/BlockingSnapshotIT.java index 63a88c8..5ec58d8 100644 --- a/src/test/java/io/debezium/connector/db2/BlockingSnapshotIT.java +++ b/src/test/java/io/debezium/connector/db2/BlockingSnapshotIT.java @@ -125,6 +125,11 @@ protected String signalTableName() { return "DEBEZIUM_SIGNAL"; } + @Override + protected String escapedTableDataCollectionId() { + return "\\\"DB2INST1\\\".\\\"A\\\""; + } + @Override protected Configuration.Builder config() { return TestHelper.defaultConfig()