我有kafka消息,我正在使用kafka连接接收器连接器将消息移动到s3。该消息有2个浮点字段 amount
以及 total_amount
.
{
"elements": [
{
"quantity": 4,
"amount": {
"bytes": "\u0004,\u001d€"
},
}
],
"total_amount": {
"bytes": "\u0004,\u001d€"
}
}
我在用转换变压器来转换磁场 amount
以及 total_amount
.
"transforms": "Cast",
"transforms.Cast.type": "org.apache.kafka.connect.transforms.Cast$Value",
"transforms.Cast.spec": amount:float64, total_amount:float64"
现在,问题是,上面的变压器只是在转换 total_amount
不转换 amount
因为 amount
嵌套在 elements
. 根据Kafka的演员阵容,这是在 TODO
访问preety weired的嵌套元素。你有什么想法或解决方法来解决这个问题吗?
暂无答案!
目前还没有任何答案,快来回答吧!