我想从KSQLDB到ElasticSearch中的表创建一个父子关系。

在ElasticSearchMap中，我只定义了联接字段：

"mappings": {
        "properties": {
            "join_field": {
              "type": "join",
              "relations": {
                "parent": "child"
              }
            },
            ...

对于ks qldb中的父元素，我只需在ks qldb中的SELECT中添加一个“Join_field”：

SELECT
    'parent' AS join_field, 
    ...

但我如何创造这个孩子呢？ElasticSearch需要以下格式：

"join_field": {
    "name": "child", 
    "parent": "1" 
}

我使用“io.confluent.connect.elasticsearch.ElasticsearchSinkConnector”将数据从Kesqldb推送到ElasticSearch。