Test failure on CI: SqlServerConnectorIT#updatePrimaryKeyTwiceWithRestartInMiddleOfTx [DBZ-4475]

Migrated from [DBZ-4475](https://issues.redhat.com/browse/DBZ-4475)

{code}
SqlServerConnectorIT.updatePrimaryKeyTwiceWithRestartInMiddleOfTx:661 expected size:<20> but was:<19> for <[SourceRecord{sourcePartition={server=server1}, sourceOffset={transaction_id=null, event_serial_no=1, commit_lsn=00000026:00000d40:000f, change_lsn=00000026:00000d40:0003}} ConnectRecord{topic='server1.dbo.tableb', kafkaPartition=null, key=Struct{id=1}, keySchema=Schema{server1.dbo.tableb.Key:STRUCT}, value=Struct{before=Struct{id=1,colb=1},source=Struct{version=1.9.0-SNAPSHOT,connector=sqlserver,name=server1,ts_ms=1639751670643,db=testDB,schema=dbo,table=tableb,change_lsn=00000026:00000d40:0003,commit_lsn=00000026:00000d40:000f,event_serial_no=1},op=d,ts_ms=1639751675889}, valueSchema=Schema{server1.dbo.tableb.Envelope:STRUCT}, timestamp=null, headers=ConnectHeaders(headers=)}, SourceRecord{sourcePartition={server=server1}, sourceOffset={transaction_id=null, event_serial_no=1, commit_lsn=00000026:00000d40:000f, change_lsn=00000026:00000d40:0005}} ConnectRecord{topic='server1.dbo.tableb', kafkaPartition=null, key=Struct{id=2}, keySchema=Schema{server1.dbo.tableb.Key:STRUCT}, value=Struct{before=Struct{id=2,colb=2},source=Struct{version=1.9.0-SNAPSHOT,connector=sqlserver,name=server1,ts_ms=1639751670643,db=testDB,schema=dbo,table=tableb,change_lsn=00000026:00000d40:0005,commit_lsn=00000026:00000d40:000f,event_serial_no=1},op=d,ts_ms=1639751675889}, valueSchema=Schema{server1.dbo.tableb.Envelope:STRUCT}, timestamp=null, headers=ConnectHeaders(headers=)}, SourceRecord{sourcePartition={server=server1}, sourceOffset={transaction_id=null, event_serial_no=1, commit_lsn=00000026:00000d40:000f, change_lsn=00000026:00000d40:0006}} ConnectRecord{topic='server1.dbo.tableb', kafkaPartition=null, key=Struct{id=3}, keySchema=Schema{server1.dbo.tableb.Key:STRUCT}, value=Struct{before=Struct{id=3,colb=3},source=Struct{version=1.9.0-SNAPSHOT,connector=sqlserver,name=server1,ts_ms=1639751670643,db=testDB,schema=dbo,table=tableb,change_lsn=00000026:00000d40:0006,commit_lsn=00000026:00000d40:000f,event_serial_no=1},op=d,ts_ms=1639751675890}, valueSchema=Schema{server1.dbo.tableb.Envelope:STRUCT}, timestamp=null, headers=ConnectHeaders(headers=)}, SourceRecord{sourcePartition={server=server1}, sourceOffset={transaction_id=null, event_serial_no=1, commit_lsn=00000026:00000d40:000f, change_lsn=00000026:00000d40:0007}} ConnectRecord{topic='server1.dbo.tableb', kafkaPartition=null, key=Struct{id=4}, keySchema=Schema{server1.dbo.tableb.Key:STRUCT}, value=Struct{before=Struct{id=4,colb=4},source=Struct{version=1.9.0-SNAPSHOT,connector=sqlserver,name=server1,ts_ms=1639751670643,db=testDB,schema=dbo,table=tableb,change_lsn=00000026:00000d40:0007,commit_lsn=00000026:00000d40:000f,event_serial_no=1},op=d,ts_ms=1639751675890}, valueSchema=Schema{server1.dbo.tableb.Envelope:STRUCT}, timestamp=null, headers=ConnectHeaders(headers=)}, SourceRecord{sourcePartition={server=server1}, sourceOffset={transaction_id=null, event_serial_no=1, commit_lsn=00000026:00000d40:000f, change_lsn=00000026:00000d40:0008}} ConnectRecord{topic='server1.dbo.tableb', kafkaPartition=null, key=Struct{id=5}, keySchema=Schema{server1.dbo.tableb.Key:STRUCT}, value=Struct{before=Struct{id=5,colb=5},source=Struct{version=1.9.0-SNAPSHOT,connector=sqlserver,name=server1,ts_ms=1639751670643,db=testDB,schema=dbo,table=tableb,change_lsn=00000026:00000d40:0008,commit_lsn=00000026:00000d40:000f,event_serial_no=1},op=d,ts_ms=1639751675891}, valueSchema=Schema{server1.dbo.tableb.Envelope:STRUCT}, timestamp=null, headers=ConnectHeaders(headers=)}, SourceRecord{sourcePartition={server=server1}, sourceOffset={transaction_id=null, event_serial_no=1, commit_lsn=00000026:00000d40:000f, change_lsn=00000026:00000d40:0009}} ConnectRecord{topic='server1.dbo.tableb', kafkaPartition=null, key=Struct{id=301}, keySchema=Schema{server1.dbo.tableb.Key:STRUCT}, value=Struct{after=Struct{id=301,colb=1},source=Struct{version=1.9.0-SNAPSHOT,connector=sqlserver,name=server1,ts_ms=1639751670643,db=testDB,schema=dbo,table=tableb,change_lsn=00000026:00000d40:0009,commit_lsn=00000026:00000d40:000f,event_serial_no=1},op=c,ts_ms=1639751675894}, valueSchema=Schema{server1.dbo.tableb.Envelope:STRUCT}, timestamp=null, headers=ConnectHeaders(headers=)}, SourceRecord{sourcePartition={server=server1}, sourceOffset={transaction_id=null, event_serial_no=1, commit_lsn=00000026:00000d40:000f, change_lsn=00000026:00000d40:000a}} ConnectRecord{topic='server1.dbo.tableb', kafkaPartition=null, key=Struct{id=302}, keySchema=Schema{server1.dbo.tableb.Key:STRUCT}, value=Struct{after=Struct{id=302,colb=2},source=Struct{version=1.9.0-SNAPSHOT,connector=sqlserver,name=server1,ts_ms=1639751670643,db=testDB,schema=dbo,table=tableb,change_lsn=00000026:00000d40:000a,commit_lsn=00000026:00000d40:000f,event_serial_no=1},op=c,ts_ms=1639751675894}, valueSchema=Schema{server1.dbo.tableb.Envelope:STRUCT}, timestamp=null, headers=ConnectHeaders(headers=)}, SourceRecord{sourcePartition={server=server1}, sourceOffset={transaction_id=null, event_serial_no=1, commit_lsn=00000026:00000d40:000f, change_lsn=00000026:00000d40:000b}} ConnectRecord{topic='server1.dbo.tableb', kafkaPartition=null, key=Struct{id=303}, keySchema=Schema{server1.dbo.tableb.Key:STRUCT}, value=Struct{after=Struct{id=303,colb=3},source=Struct{version=1.9.0-SNAPSHOT,connector=sqlserver,name=server1,ts_ms=1639751670643,db=testDB,schema=dbo,table=tableb,change_lsn=00000026:00000d40:000b,commit_lsn=00000026:00000d40:000f,event_serial_no=1},op=c,ts_ms=1639751675898}, valueSchema=Schema{server1.dbo.tableb.Envelope:STRUCT}, timestamp=null, headers=ConnectHeaders(headers=)}, SourceRecord{sourcePartition={server=server1}, sourceOffset={transaction_id=null, event_serial_no=1, commit_lsn=00000026:00000d40:000f, change_lsn=00000026:00000d40:000c}} ConnectRecord{topic='server1.dbo.tableb', kafkaPartition=null, key=Struct{id=304}, keySchema=Schema{server1.dbo.tableb.Key:STRUCT}, value=Struct{after=Struct{id=304,colb=4},source=Struct{version=1.9.0-SNAPSHOT,connector=sqlserver,name=server1,ts_ms=1639751670643,db=testDB,schema=dbo,table=tableb,change_lsn=00000026:00000d40:000c,commit_lsn=00000026:00000d40:000f,event_serial_no=1},op=c,ts_ms=1639751675898}, valueSchema=Schema{server1.dbo.tableb.Envelope:STRUCT}, timestamp=null, headers=ConnectHeaders(headers=)}, SourceRecord{sourcePartition={server=server1}, sourceOffset={transaction_id=null, event_serial_no=1, commit_lsn=00000026:00000d40:000f, change_lsn=00000026:00000d40:000d}} ConnectRecord{topic='server1.dbo.tableb', kafkaPartition=null, key=Struct{id=305}, keySchema=Schema{server1.dbo.tableb.Key:STRUCT}, value=Struct{after=Struct{id=305,colb=5},source=Struct{version=1.9.0-SNAPSHOT,connector=sqlserver,name=server1,ts_ms=1639751670643,db=testDB,schema=dbo,table=tableb,change_lsn=00000026:00000d40:000d,commit_lsn=00000026:00000d40:000f,event_serial_no=1},op=c,ts_ms=1639751675898}, valueSchema=Schema{server1.dbo.tableb.Envelope:STRUCT}, timestamp=null, headers=ConnectHeaders(headers=)}, SourceRecord{sourcePartition={server=server1}, sourceOffset={transaction_id=null, event_serial_no=1, commit_lsn=00000026:00000d48:0009, change_lsn=00000026:00000d48:0003}} ConnectRecord{topic='server1.dbo.tableb', kafkaPartition=null, key=Struct{id=301}, keySchema=Schema{server1.dbo.tableb.Key:STRUCT}, value=Struct{before=Struct{id=301,colb=1},source=Struct{version=1.9.0-SNAPSHOT,connector=sqlserver,name=server1,ts_ms=1639751670643,db=testDB,schema=dbo,table=tableb,change_lsn=00000026:00000d48:0003,commit_lsn=00000026:00000d48:0009,event_serial_no=1},op=d,ts_ms=1639751675899}, valueSchema=Schema{server1.dbo.tableb.Envelope:STRUCT}, timestamp=null, headers=ConnectHeaders(headers=)}, SourceRecord{sourcePartition={server=server1}, sourceOffset={transaction_id=null, event_serial_no=2, commit_lsn=00000026:00000d48:0009, change_lsn=00000026:00000d48:0003}} ConnectRecord{topic='server1.dbo.tableb', kafkaPartition=null, key=Struct{id=301}, keySchema=Schema{server1.dbo.tableb.Key:STRUCT}, value=Struct{after=Struct{id=301,colb=1},source=Struct{version=1.9.0-SNAPSHOT,connector=sqlserver,name=server1,ts_ms=1639751670643,db=testDB,schema=dbo,table=tableb,change_lsn=00000026:00000d48:0003,commit_lsn=00000026:00000d48:0009,event_serial_no=2},op=c,ts_ms=1639751675899}, valueSchema=Schema{server1.dbo.tableb.Envelope:STRUCT}, timestamp=null, headers=ConnectHeaders(headers=)}, SourceRecord{sourcePartition={server=server1}, sourceOffset={transaction_id=null, event_serial_no=1, commit_lsn=00000026:00000d48:0009, change_lsn=00000026:00000d48:0004}} ConnectRecord{topic='server1.dbo.tableb', kafkaPartition=null, key=Struct{id=302}, keySchema=Schema{server1.dbo.tableb.Key:STRUCT}, value=Struct{before=Struct{id=302,colb=2},source=Struct{version=1.9.0-SNAPSHOT,connector=sqlserver,name=server1,ts_ms=1639751670643,db=testDB,schema=dbo,table=tableb,change_lsn=00000026:00000d48:0004,commit_lsn=00000026:00000d48:0009,event_serial_no=1},op=d,ts_ms=1639751675900}, valueSchema=Schema{server1.dbo.tableb.Envelope:STRUCT}, timestamp=null, headers=ConnectHeaders(headers=)}, SourceRecord{sourcePartition={server=server1}, sourceOffset={transaction_id=null, event_serial_no=2, commit_lsn=00000026:00000d48:0009, change_lsn=00000026:00000d48:0004}} ConnectRecord{topic='server1.dbo.tableb', kafkaPartition=null, key=Struct{id=302}, keySchema=Schema{server1.dbo.tableb.Key:STRUCT}, value=Struct{after=Struct{id=302,colb=2},source=Struct{version=1.9.0-SNAPSHOT,connector=sqlserver,name=server1,ts_ms=1639751670643,db=testDB,schema=dbo,table=tableb,change_lsn=00000026:00000d48:0004,commit_lsn=00000026:00000d48:0009,event_serial_no=2},op=c,ts_ms=1639751675900}, valueSchema=Schema{server1.dbo.tableb.Envelope:STRUCT}, timestamp=null, headers=ConnectHeaders(headers=)}, SourceRecord{sourcePartition={server=server1}, sourceOffset={transaction_id=null, event_serial_no=2, commit_lsn=00000026:00000d48:0009, change_lsn=00000026:00000d48:0005}} ConnectRecord{topic='server1.dbo.tableb', kafkaPartition=null, key=Struct{id=303}, keySchema=Schema{server1.dbo.tableb.Key:STRUCT}, value=Struct{after=Struct{id=303,colb=3},source=Struct{version=1.9.0-SNAPSHOT,connector=sqlserver,name=server1,ts_ms=1639751670643,db=testDB,schema=dbo,table=tableb,change_lsn=00000026:00000d48:0005,commit_lsn=00000026:00000d48:0009,event_serial_no=2},op=c,ts_ms=1639751765991}, valueSchema=Schema{server1.dbo.tableb.Envelope:STRUCT}, timestamp=null, headers=ConnectHeaders(headers=)}, SourceRecord{sourcePartition={server=server1}, sourceOffset={transaction_id=null, event_serial_no=1, commit_lsn=00000026:00000d48:0009, change_lsn=00000026:00000d48:0006}} ConnectRecord{topic='server1.dbo.tableb', kafkaPartition=null, key=Struct{id=304}, keySchema=Schema{server1.dbo.tableb.Key:STRUCT}, value=Struct{before=Struct{id=304,colb=4},source=Struct{version=1.9.0-SNAPSHOT,connector=sqlserver,name=server1,ts_ms=1639751670643,db=testDB,schema=dbo,table=tableb,change_lsn=00000026:00000d48:0006,commit_lsn=00000026:00000d48:0009,event_serial_no=1},op=d,ts_ms=1639751765991}, valueSchema=Schema{server1.dbo.tableb.Envelope:STRUCT}, timestamp=null, headers=ConnectHeaders(headers=)}, SourceRecord{sourcePartition={server=server1}, sourceOffset={transaction_id=null, event_serial_no=2, commit_lsn=00000026:00000d48:0009, change_lsn=00000026:00000d48:0006}} ConnectRecord{topic='server1.dbo.tableb', kafkaPartition=null, key=Struct{id=304}, keySchema=Schema{server1.dbo.tableb.Key:STRUCT}, value=Struct{after=Struct{id=304,colb=4},source=Struct{version=1.9.0-SNAPSHOT,connector=sqlserver,name=server1,ts_ms=1639751670643,db=testDB,schema=dbo,table=tableb,change_lsn=00000026:00000d48:0006,commit_lsn=00000026:00000d48:0009,event_serial_no=2},op=c,ts_ms=1639751765991}, valueSchema=Schema{server1.dbo.tableb.Envelope:STRUCT}, timestamp=null, headers=ConnectHeaders(headers=)}, SourceRecord{sourcePartition={server=server1}, sourceOffset={transaction_id=null, event_serial_no=1, commit_lsn=00000026:00000d48:0009, change_lsn=00000026:00000d48:0007}} ConnectRecord{topic='server1.dbo.tableb', kafkaPartition=null, key=Struct{id=305}, keySchema=Schema{server1.dbo.tableb.Key:STRUCT}, value=Struct{before=Struct{id=305,colb=5},source=Struct{version=1.9.0-SNAPSHOT,connector=sqlserver,name=server1,ts_ms=1639751670643,db=testDB,schema=dbo,table=tableb,change_lsn=00000026:00000d48:0007,commit_lsn=00000026:00000d48:0009,event_serial_no=1},op=d,ts_ms=1639751765992}, valueSchema=Schema{server1.dbo.tableb.Envelope:STRUCT}, timestamp=null, headers=ConnectHeaders(headers=)}, SourceRecord{sourcePartition={server=server1}, sourceOffset={transaction_id=null, event_serial_no=2, commit_lsn=00000026:00000d48:0009, change_lsn=00000026:00000d48:0007}} ConnectRecord{topic='server1.dbo.tableb', kafkaPartition=null, key=Struct{id=305}, keySchema=Schema{server1.dbo.tableb.Key:STRUCT}, value=Struct{after=Struct{id=305,colb=5},source=Struct{version=1.9.0-SNAPSHOT,connector=sqlserver,name=server1,ts_ms=1639751670643,db=testDB,schema=dbo,table=tableb,change_lsn=00000026:00000d48:0007,commit_lsn=00000026:00000d48:0009,event_serial_no=2},op=c,ts_ms=1639751765994}, valueSchema=Schema{server1.dbo.tableb.Envelope:STRUCT}, timestamp=null, headers=ConnectHeaders(headers=)}]>
{code}