@@ -520,9 +520,10 @@ func TestCDCIterator_NextN(t *testing.T) {
520
520
is .Equal (r .Operation , opencdc .OperationCreate )
521
521
is .Equal (r .Key .(opencdc.StructuredData )["id" ], int64 (j + 11 ))
522
522
change := r .Payload
523
- payload := change .After .(opencdc.StructuredData )
524
- is .Equal (payload ["column1" ], fmt .Sprintf ("test-%d" , j + 1 ))
525
- is .Equal (payload ["column2" ], int32 ((j + 1 )* 100 ))
523
+ data := change .After .(opencdc.StructuredData )
524
+ is .Equal (data ["column1" ], fmt .Sprintf ("test-%d" , j + 1 ))
525
+ //nolint:gosec // no risk to overflow
526
+ is .Equal (data ["column2" ], (int32 (j )+ 1 )* 100 )
526
527
}
527
528
})
528
529
@@ -549,8 +550,10 @@ func TestCDCIterator_NextN(t *testing.T) {
549
550
is .Equal (r .Operation , opencdc .OperationCreate )
550
551
is .Equal (r .Key .(opencdc.StructuredData )["id" ], int64 (j + 21 ))
551
552
change := r .Payload
552
- payload := change .After .(opencdc.StructuredData )
553
- is .Equal (payload ["column1" ], fmt .Sprintf ("test-%d" , j + 1 ))
553
+ data := change .After .(opencdc.StructuredData )
554
+ is .Equal (data ["column1" ], fmt .Sprintf ("test-%d" , j + 1 ))
555
+ //nolint:gosec // no risk to overflow
556
+ is .Equal (data ["column2" ], (int32 (j )+ 1 )* 100 )
554
557
}
555
558
})
556
559
0 commit comments