kafka jdbc接收器连接器,用于具有不同列名的现有表?

soat7uwm  于 2021-06-04  发布在  Kafka
关注(0)|答案(0)|浏览(307)

我正在尝试创建一个jdbc接收器连接器,它从一个主题中读取数据并将数据放入一个现有的表中。问题是它不是与表的1:1Map。相反,所有的列名都与我在消息中看到的不同
以下是我在主题中的信息:

{
 "dealNo":"6666777",
"exception": 
{"code":12345E
 "desc": couldnot process the issue,  
},
}

数据库表Map如下:error\u tb

id: auto generated sequence
srcId : "APP" (need to pass default value) 
factory : dealNo (from json)
body : here i need to pass the entire message
description : exception (from json)

有人能指导我如何应用转换吗?我是新来的,不知道如何才能实现

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题