From a13004085d92652808ad2c5c63e663404f0c354e Mon Sep 17 00:00:00 2001 From: Artem Shubovych Date: Mon, 29 Jan 2024 18:05:23 +1100 Subject: [PATCH] DBZ-7250 Fix VitessConnectorTaskTest failure --- .../io/debezium/connector/vitess/VitessConnectorTaskTest.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/test/java/io/debezium/connector/vitess/VitessConnectorTaskTest.java b/src/test/java/io/debezium/connector/vitess/VitessConnectorTaskTest.java index 0ff738e9..658f6282 100644 --- a/src/test/java/io/debezium/connector/vitess/VitessConnectorTaskTest.java +++ b/src/test/java/io/debezium/connector/vitess/VitessConnectorTaskTest.java @@ -77,7 +77,7 @@ public void shouldReadOffsetsWhenTaskOffsetStorageDisabled() { task.initialize(helper.getSourceTaskContext()); ChangeEventSourceCoordinator coordinator = task.start(config); String expectedMessage = String.format( - "Found previous partition offset VitessPartition [sourcePartition={server=test_server}]: {transaction_id=null, vgtid=%s}", + "Found previous partition offset VitessPartition [sourcePartition={server=test_server}]: {vgtid=%s}", VGTID_JSON); assertThat(logInterceptor.containsMessage(expectedMessage)).isTrue(); }