diff --git a/src/main/java/io/debezium/connector/vitess/Vgtid.java b/src/main/java/io/debezium/connector/vitess/Vgtid.java index 15b5c985..8a0de71a 100644 --- a/src/main/java/io/debezium/connector/vitess/Vgtid.java +++ b/src/main/java/io/debezium/connector/vitess/Vgtid.java @@ -105,6 +105,7 @@ public boolean willTriggerVStreamCopy() { } return false; } + public Vgtid getLocalVgtid(String shard) { return Vgtid.of(List.of(getShardGtid(shard))); }