diff --git a/lib/debezium/converters/bit_varying.go b/lib/debezium/converters/bit_varying.go index 269d9a7a..cb508730 100644 --- a/lib/debezium/converters/bit_varying.go +++ b/lib/debezium/converters/bit_varying.go @@ -14,7 +14,7 @@ func NewBitVaryingConverter(optionalCharMaxLength int) BitVaryingConverter { return BitVaryingConverter{optionalCharMaxLength: optionalCharMaxLength} } -func (BitVaryingConverter) ToField(name string) Field { +func (BitVaryingConverter) ToField(name string) debezium.Field { return debezium.Field{ FieldName: name, DebeziumType: debezium.Bits, @@ -38,5 +38,5 @@ func (b BitVaryingConverter) Convert(value any) (any, error) { } } - return stringToByteA(stringValue), nil + return stringToByteA(stringValue) } diff --git a/lib/postgres/scanner_test.go b/lib/postgres/scanner_test.go index 25f04414..68fea295 100644 --- a/lib/postgres/scanner_test.go +++ b/lib/postgres/scanner_test.go @@ -93,7 +93,7 @@ func TestScanAdapter_ParsePrimaryKeyValueForOverrides(t *testing.T) { name: "unsupported data type", dataType: schema.Array, value: "1234", - expectedErr: `DataType(21) for column "col" is not supported for use as a primary key`, + expectedErr: `DataType(22) for column "col" is not supported for use as a primary key`, }, { name: "boolean - malformed",