Debezium系列之：处理decimal数据类型org.apache.kafka.connect.data.Decimal
- 一、背景
- 二、Debezium处理decimal数据类型三种方式
- 三、precise方式字段类型和数据样式
- 四、使用代码处理Decimal数据
一、背景
- 源库id字段类型是DECIMAL[(M[,D])]，id的值是2
- debezium采集后数据类型变为bytes，id的值是Ag==
- 这是由设置的Debezium处理decimal数据类型的模式决定的，模式设置为了decimal.handling.mode=precise
- 现在消费数据需要把id的值从Ag==转换回为2
二、Debezium处理decimal数据类型三种方式
Debezium处理decimal数据类型支持以下三种方式：
- decimal.handling.mode=precise
- decimal.handling.mode=double
- decimal.handling.mode=string
decimal.handling.mode=precise
| mysql类型 | 文字类型 | 语义类型 |
|---|---|---|
