diff --git a/src/main/java/io/debezium/connector/vitess/VitessTaskContext.java b/src/main/java/io/debezium/connector/vitess/VitessTaskContext.java
index 6e291162..800b3dd8 100644
--- a/src/main/java/io/debezium/connector/vitess/VitessTaskContext.java
+++ b/src/main/java/io/debezium/connector/vitess/VitessTaskContext.java
@@ -11,7 +11,7 @@
 public class VitessTaskContext extends CdcSourceTaskContext {
 
     public VitessTaskContext(VitessConnectorConfig config, VitessDatabaseSchema schema) {
-        super(config.getContextName(), config.getLogicalName(), getTaskId(config), config.getCustomMetricTags(), schema::tableIds);
+        super(config, getTaskId(config), config.getCustomMetricTags(), schema::tableIds);
     }
 
     public static String getTaskId(VitessConnectorConfig config) {