Flink1.17.1 upsert-kafka连接器好像不支持时间戳
·
博主在测试的时候发现,普通的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连接器不支持时间戳的反序列化,如果大家有验证支持的,欢迎评论留言,感谢~
更多推荐




所有评论(0)