From d66def0cdaf3995092042aa0d445969e824ef827 Mon Sep 17 00:00:00 2001 From: mfvitale Date: Mon, 12 Aug 2024 17:02:19 +0200 Subject: [PATCH] DBZ-8035 Align core changes --- .../java/io/debezium/connector/vitess/VitessTaskContext.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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) {