diff --git a/src/main/java/io/debezium/connector/db2/Db2TaskContext.java b/src/main/java/io/debezium/connector/db2/Db2TaskContext.java index 24e663f..d396f6b 100644 --- a/src/main/java/io/debezium/connector/db2/Db2TaskContext.java +++ b/src/main/java/io/debezium/connector/db2/Db2TaskContext.java @@ -16,6 +16,6 @@ public class Db2TaskContext extends CdcSourceTaskContext { public Db2TaskContext(Db2ConnectorConfig config, Db2DatabaseSchema schema) { - super(config.getContextName(), config.getLogicalName(), config.getCustomMetricTags(), schema::tableIds); + super(config, config.getCustomMetricTags(), schema::tableIds); } }