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插件设置认证
- 作者:OldCamel
- 链接:https://blog.oldcamel.cc/article/22
- 声明:本文采用 CC BY-NC-SA 4.0 许可协议,转载请注明出处。