博主在测试的时候发现,普通的kafka连接器使用时间戳TIMESTAMP或者TIMESTAMP_LIZ没有问题,但是upsert-kafka连接器使用的时候就是报错
报错的信息如下:

Caused by: java.io.IOException: Failed to deserialize consumer record ConsumerRecord
Caused by: java.io.IOException: Failed to deserialize JSON
Caused by: org.apache.flink.formats.json.JsonToRowDataConverters$JsonParseException: Fail to deserialize at field: record_time.
Caused by: java.time.format.DateTimeParseException: Text '2025-03-06 18:13:12.33' could not be parsed at index 22

具体原因看下来是upsert-kafka连接器不支持时间戳的反序列化,如果大家有验证支持的,欢迎评论留言,感谢~

Logo

汇聚全球AI编程工具,助力开发者即刻编程。

更多推荐