我想从监控 mysql 表的 kafka 主题创建一个流。 mysql 表具有十进制(16,4)类型的列,当我使用此命令创建流时:
create stream test with (KAFKA_TOPIC='dbServer.Kafka.DailyUdr',VALUE_FORMAT='AVRO');
流创建并运行,但十进制(16,4)类型的列不出现在结果流中。
源主题值模式:
{
“类型”:“记录”,
“名称”:“信封”,
“命名空间”:“dbServer.Kafka.DailyUdr”,
“领域”:[
{
“名称”:“之前”,
“类型”: [
“空值”,
{
“类型”:“记录”,
“名称”:“价值”,
“领域”:[
{
“名称”:“用户 ID”,
“类型”:“整数”
},
{
"name": "国家代码",
“类型”:“字符串”
},
{
"name": "TotalInputOcted",
“类型”:“整数”
},
{
"name": "TotalOutputOcted",
“类型”:“整数”
},
{
“名称日期”,
“类型”:“字符串”
},
{
“名称”:“服务”,
“类型”:“字符串”
},
{
"name": "decimalCol",
“类型”: [
“空值”,
{
“类型”:“字节”,
“规模”:4,
“精度”:16,
“连接版本”:1,
“连接参数”:{
“规模”:“4”,
“connect.decimal.precision”:“16”
},
"connect.name": "org.apache.kafka.connect.data.Decimal",
“逻辑类型”:“十进制”
}
],
“默认”:空
}
],
“connect.name”:“dbServer.Kafka.DailyUdr.Value”
}
],
“默认”:空
},
{
“以...命名”,
“类型”: [
“空值”,
“价值”
],
“默认”:空
},
{
“名称”:“来源”,
“类型”: {
“类型”:“记录”,
“名称”:“来源”,
“命名空间”:“io.debezium.connector.mysql”,
“领域”:[
{
“名称”:“版本”,
“类型”: [
“空值”,
“细绳”
],
“默认”:空
},
{
“名称”:“连接器”,
“类型”: [
“空值”,
“细绳”
],
“默认”:空
},
{
“名称”:“名称”,
“类型”:“字符串”
},
{
"name": "server_id",
“类型”:“长”
},
{
“名称”:“ts_sec”,
“类型”:“长”
},
{
“名称”:“gtid”,
“类型”: [
“空值”,
“细绳”
],
“默认”:空
},
{
“名称”:“文件”,
“类型”:“字符串”
},
{
“名称”:“位置”,
“类型”:“长”
},
{
“名称”:“行”,
“类型”:“整数”
},
{
“名称”:“快照”,
“类型”: [
{
“类型”:“布尔”,
“连接。默认”:假
},
“空值”
],
“默认”:假
},
{
“名称”:“线程”,
“类型”: [
“空值”,
“长”
],
“默认”:空
},
{
“名称”:“分贝”,
“类型”: [
“空值”,
“细绳”
],
“默认”:空
},
{
“名称”:“表”,
“类型”: [
“空值”,
“细绳”
],
“默认”:空
},
{
“名称”:“查询”,
“类型”: [
“空值”,
“细绳”
],
“默认”:空
}
],
“connect.name”:“io.debezium.connector.mysql.Source”
}
},
{
“名称”:“操作”,
“类型”:“字符串”
},
{
“名称”:“ts_ms”,
“类型”: [
“空值”,
“长”
],
“默认”:空
}
],
“connect.name”:“dbServer.Kafka.DailyUdr.Envelope”
}
我的问题在十进制列中