fix linter errors

opencdc/data.go

@@ -88,8 +88,10 @@ func (d RawData) Clone() Data {
 func (d RawData) MarshalJSON(ctx context.Context) ([]byte, error) {
 	if ctx != nil {
 		s := ctx.Value(jsonMarshalOptionsCtxKey{})
+		//nolint:forcetypeassert // We know the type of the value.
 		if s != nil && s.(*JSONMarshalOptions).RawDataAsString {
 			// We should serialize RawData as a string.
+			//nolint:wrapcheck // If we didn't implement MarshalJSON this would be done by the json package.
 			return json.Marshal(string(d))
 		}
 	}

opencdc/serializer.go

@@ -16,6 +16,7 @@ package opencdc
 
 import (
 	"context"
+	"fmt"
 
 	"github.com/goccy/go-json"
 )
@@ -38,5 +39,9 @@ func (s JSONSerializer) Serialize(r Record) ([]byte, error) {
 		//  instead of pointer.
 		s = JSONSerializer{}
 	}()
-	return json.MarshalContext(ctx, r)
+	bytes, err := json.MarshalContext(ctx, r)
+	if err != nil {
+		return nil, fmt.Errorf("failed to serialize record to JSON: %w", err)
+	}
+	return bytes, nil
 }

opencdc/serializer_test.go

@@ -22,8 +22,6 @@ import (
 )
 
 func TestJSONSerializer(t *testing.T) {
-	t.Skip()
-	is := is.New(t)
 	rec := Record{
 		Position:  Position("standing"),
 		Operation: OperationUpdate,
@@ -62,6 +60,7 @@ func TestJSONSerializer(t *testing.T) {
 
 	for _, tc := range testCases {
 		t.Run(tc.name, func(t *testing.T) {
+			is := is.New(t)
 			rec.SetSerializer(tc.serializer)
 			b := rec.Bytes()
 			is.Equal(cmp.Diff(string(b), tc.want), "")