KSQLDB:ElasticSearch的父子联接

wnrlj8wa  于 2022-09-20  发布在  ElasticSearch
关注(0)|答案(1)|浏览(163)

我想从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。

bis0qfac

bis0qfac1#

它还没有实施。希望能快点。https://github.com/confluentinc/kafka-connect-elasticsearch/pull/558

在等待正式发布的同时。可以使用此提交https://github.com/confluentinc/kafka-connect-elasticsearch/tree/2e25ed8329fad1dc15ba5711e7ed32e0c270dd5d构建支持路由的版本

创建接收器时需要此配置:“routing.field.name”=“PARENTID”

在KSQLDB中,选择Use struct:struct(name:=‘Child’,parent:=parentid)as Join_field,\

相关问题