DBZ-6603 Support for custom tags in the connector metrics

debezium · Jul 13, 2023 · 0cc90e1 · 0cc90e1
1 parent 63a94ac
commit 0cc90e1
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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), schema::tableIds);
+        super(config.getContextName(), config.getLogicalName(), getTaskId(config), config.getCustomMetricTags(), schema::tableIds);
     }
 
     public static String getTaskId(VitessConnectorConfig config) {