Intermittent test failures on CI: EventProcessingFailureHandlingIT

EventProcessingFailureHandlingIT.ignore:121 expected size:<5> but was:<3> for <[SourceRecord{sourcePartition={server=server1}, sourceOffset={transaction_id=null, event_serial_no=1, commit_lsn=00000026:00000d30:001c, change_lsn=00000026:00000d30:001b}} ConnectRecord{topic='server1.dbo.tablea', kafkaPartition=null, key=Struct{id=10}, keySchema=Schema{server1.dbo.tablea.Key:STRUCT}, value=Struct{after=Struct{id=10,cola=a},source=Struct{version=1.7.0-SNAPSHOT,connector=sqlserver,name=server1,ts_ms=1631543651073,db=testDB,schema=dbo,table=tablea,change_lsn=00000026:00000d30:001b,commit_lsn=00000026:00000d30:001c,event_serial_no=1},op=c,ts_ms=1631543656370}, valueSchema=Schema{server1.dbo.tablea.Envelope:STRUCT}, timestamp=null, headers=ConnectHeaders(headers=)}, SourceRecord{sourcePartition={server=server1}, sourceOffset={transaction_id=null, event_serial_no=1, commit_lsn=00000026:00000d40:0003, change_lsn=00000026:00000d40:0002}} ConnectRecord{topic='server1.dbo.tablea', kafkaPartition=null, key=Struct{id=11}, keySchema=Schema{server1.dbo.tablea.Key:STRUCT}, value=Struct{after=Struct{id=11,cola=a},source=Struct{version=1.7.0-SNAPSHOT,connector=sqlserver,name=server1,ts_ms=1631543651080,db=testDB,schema=dbo,table=tablea,change_lsn=00000026:00000d40:0002,commit_lsn=00000026:00000d40:0003,event_serial_no=1},op=c,ts_ms=1631543656370}, valueSchema=Schema{server1.dbo.tablea.Envelope:STRUCT}, timestamp=null, headers=ConnectHeaders(headers=)}, SourceRecord{sourcePartition={server=server1}, sourceOffset={transaction_id=null, event_serial_no=1, commit_lsn=00000026:00000d50:0003, change_lsn=00000026:00000d50:0002}} ConnectRecord{topic='server1.dbo.tablea', kafkaPartition=null, key=Struct{id=12}, keySchema=Schema{server1.dbo.tablea.Key:STRUCT}, value=Struct{after=Struct{id=12,cola=a},source=Struct{version=1.7.0-SNAPSHOT,connector=sqlserver,name=server1,ts_ms=1631543651087,db=testDB,schema=dbo,table=tablea,change_lsn=00000026:00000d50:0002,commit_lsn=00000026:00000d50:0003,event_serial_no=1},op=c,ts_ms=1631543656370}, valueSchema=Schema{server1.dbo.tablea.Envelope:STRUCT}, timestamp=null, headers=ConnectHeaders(headers=)}]>
2021-09-13T14:44:51.4552725Z [ERROR]   EventProcessingFailureHandlingIT.warn:85 expected size:<5> but was:<3> for <[SourceRecord{sourcePartition={server=server1}, sourceOffset={transaction_id=null, event_serial_no=1, commit_lsn=00000026:00000d28:001c, change_lsn=00000026:00000d28:001b}} ConnectRecord{topic='server1.dbo.tablea', kafkaPartition=null, key=Struct{id=10}, keySchema=Schema{server1.dbo.tablea.Key:STRUCT}, value=Struct{after=Struct{id=10,cola=a},source=Struct{version=1.7.0-SNAPSHOT,connector=sqlserver,name=server1,ts_ms=1631543679020,db=testDB,schema=dbo,table=tablea,change_lsn=00000026:00000d28:001b,commit_lsn=00000026:00000d28:001c,event_serial_no=1},op=c,ts_ms=1631543684518}, valueSchema=Schema{server1.dbo.tablea.Envelope:STRUCT}, timestamp=null, headers=ConnectHeaders(headers=)}, SourceRecord{sourcePartition={server=server1}, sourceOffset={transaction_id=null, event_serial_no=1, commit_lsn=00000026:00000d40:0003, change_lsn=00000026:00000d40:0002}} ConnectRecord{topic='server1.dbo.tablea', kafkaPartition=null, key=Struct{id=11}, keySchema=Schema{server1.dbo.tablea.Key:STRUCT}, value=Struct{after=Struct{id=11,cola=a},source=Struct{version=1.7.0-SNAPSHOT,connector=sqlserver,name=server1,ts_ms=1631543679030,db=testDB,schema=dbo,table=tablea,change_lsn=00000026:00000d40:0002,commit_lsn=00000026:00000d40:0003,event_serial_no=1},op=c,ts_ms=1631543684518}, valueSchema=Schema{server1.dbo.tablea.Envelope:STRUCT}, timestamp=null, headers=ConnectHeaders(headers=)}, SourceRecord{sourcePartition={server=server1}, sourceOffset={transaction_id=null, event_serial_no=1, commit_lsn=00000026:00000d50:0003, change_lsn=00000026:00000d50:0002}} ConnectRecord{topic='server1.dbo.tablea', kafkaPartition=null, key=Struct{id=12}, keySchema=Schema{server1.dbo.tablea.Key:STRUCT}, value=Struct{after=Struct{id=12,cola=a},source=Struct{version=1.7.0-SNAPSHOT,connector=sqlserver,name=server1,ts_ms=1631543679033,db=testDB,schema=dbo,table=tablea,change_lsn=00000026:00000d50:0002,commit_lsn=00000026:00000d50:0003,event_serial_no=1},op=c,ts_ms=1631543684518}, valueSchema=Schema{server1.dbo.tablea.Envelope:STRUCT}, timestamp=null, headers=ConnectHeaders(headers=)}]>