diff --git a/lib/debezium/schema.go b/lib/debezium/schema.go index 9acb6946b..be1dc32d0 100644 --- a/lib/debezium/schema.go +++ b/lib/debezium/schema.go @@ -86,6 +86,8 @@ func (f Field) ToValueConverter() converters.ValueConverter { return converters.DateTimeWithTimezone{} case TimeWithTimezone: return converters.TimeWithTimezone{} + case GeometryPointType: + return converters.GeometryPoint{} } return nil