kafka connect:如何使用kafka connect transfor转换嵌套属性?

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

我有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的嵌套元素。你有什么想法或解决方法来解决这个问题吗?

暂无答案!

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

相关问题