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();
     }