从Kafka更新Elasticsearch中的部分文档

例如,源1具有以下模式

{
    "id": 123
    "some_value": "yo"
    "details": {}
}

来源2有以下内容

{
    "id": 123
    "reference": 1
},
{
    "id": 123
    "reference": 2  
}

{
    "id": 123
    "some_value": "yo"
    "details": [
        {
            "id": 123
            "reference": 1
        },
        {
            "id": 123
            "reference": 2
        }
    ]
}

我试过用卡夫卡的变换来描述井菲尔德,但没有成功