Lazy loaded image
技术分享
🎭Flink Sql 实现CDC数据实时同步特殊处理
00 分钟
2019-12-2
2024-12-5
type
status
date
slug
summary
tags
category
icon
password

1、decimal 类型在kafka中解析为乱码

kafka connect 插件设置 “decimal.handling.mode”: “string” 属性。将decimal解析为字符串
sql语句中将字符串转换为数字 用CAST(字段名称) AS INT) 函数 INT可根据不同类型的数字替换为不同的目标类型(DECIMAL(10,4) BIGINT 等)

2、日期处理

kafka中人日期类型会解析成时间戳,可用TO_TIMESTAMP + FROM_UNIXTIME做转换,注意处理时区问题
oracle日期类型处理精度+时区:
其他数据库日期类型只处理日期

3、cdc数据插入设置主键

4、kafka sink sasl connect插件设置认证

上一篇
VictoriaMetrics(三)安装kube-prometheus
下一篇
Kubernetes 问题处理记录

评论
Loading...