Fix bug

artie-labs · Apr 6, 2024 · 741a302 · 741a302
1 parent dafd13f
commit 741a302
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/lib/cdc/util/parse.go b/lib/cdc/util/parse.go
@@ -34,7 +34,7 @@ func parseField(field debezium.Field, value any) (any, error) {
 		case debezium.KafkaDecimalType:
 			bytes, err := debezium.ToBytes(value)
 			if err != nil {
-				return nil, nil
+				return nil, err
 			}
 			return field.DecodeDecimal(bytes)
 		case debezium.KafkaVariableNumericType: