From e198cb0f4527a40f653bf2e308af7dcb360cc1dc Mon Sep 17 00:00:00 2001
From: Jiri Pechanec <jpechane@redhat.com>
Date: Thu, 23 Jan 2020 13:05:13 +0100
Subject: [PATCH] DBZ-1052 Fix test for offset size

---
 .../test/java/io/debezium/connector/sqlserver/SnapshotIT.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SnapshotIT.java b/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SnapshotIT.java
index ba0462024..7e254dd15 100644
--- a/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SnapshotIT.java
+++ b/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SnapshotIT.java
@@ -222,7 +222,7 @@ private void testStreaming() throws SQLException, InterruptedException {
             final Struct value1 = (Struct) record1.value();
             assertRecord(key1, expectedKey1);
             assertRecord((Struct) value1.get("after"), expectedRow1);
-            assertThat(record1.sourceOffset()).hasSize(3);
+            assertThat(record1.sourceOffset()).hasSize(4);
 
             Assert.assertTrue(record1.sourceOffset().containsKey("change_lsn"));
             Assert.assertTrue(record1.sourceOffset().containsKey("commit_lsn"));