我将以下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
有什么建议吗?
暂无答案!
目前还没有任何答案,快来回答吧!