kafka连接将数组转换为对象

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

我将以下json发送给kafka(我无法控制发送给kafka的数据)

{
  "id":"unique-event-id",
  "type":"CONTRACT_EVENT",
  "details":{
    "nonIndexedParameters":[
      {"type":"uint256","value":10},
      {"type":"string","value":"StringValue"}
    ]
  },
    "retries":0
}

然后我有一个接收器连接器,将数据发送到elastic。
我希望我的连接器将“非索引参数”转换为如下对象

{
  "id":"unique-event-id",
  "type":"CONTRACT_EVENT",
  "details":{
    "params":{
      "count":10,
      "user":"StringValue"
    }
  },
    "retries":0
}

我已经写了一个自定义的java插件,但我宁愿这样做与内置的smt的。这可能吗?
我最初的想法是修饰结构并从每个元素中获取值,然后使用insertfeild,但是我得到了错误

Flatten transformation does not support class java.util.ArrayList

有什么建议吗?

暂无答案!

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

相关问题