diff --git a/lib/debezium/types.go b/lib/debezium/types.go index cdc6596d0..86c3bfbc5 100644 --- a/lib/debezium/types.go +++ b/lib/debezium/types.go @@ -161,6 +161,8 @@ func (f Field) ParseValue(value any) (any, error) { if bytes, ok := value.([]byte); ok { // Preserve existing behavior by base64 encoding []byte values to a string. + // TODO: Look into inverting this logic so that in the case the field type is "bytes" but the value is a string we + // base64 decode it here, then things downstream from here can just deal with []byte values. return base64.StdEncoding.EncodeToString(bytes), nil }