Support more integer types

lib/cdc/util/parse.go

@@ -15,12 +15,21 @@ func parseField(field debezium.Field, value any) (any, error) {
 
 	// Check if the field is an integer and requires us to cast it as such.
 	if field.IsInteger() {
-		valFloat, isOk := value.(float64)
-		if !isOk {
-			return nil, fmt.Errorf("failed to cast value to float64")
+		switch typedValue := value.(type) {
+		case int:
+			return int64(typedValue), nil
+		case int16:
+			return int64(typedValue), nil
+		case int32:
+			return int64(typedValue), nil
+		case int64:
+			return typedValue, nil
+		case float64:
+			// The JSON encoding and decoding process converts all integers to float64.
+			return int64(typedValue), nil
+		default:
+			return nil, fmt.Errorf("unsupported integer type: %T", value)
 		}
-
-		return int(valFloat), nil
 	}
 
 	if valid, supportedType := debezium.RequiresSpecialTypeCasting(field.DebeziumType); valid {