KSQLDB:父母子女加入elasticsearch

Question

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

在elasticsearch映射中，我只定义了联接字段：

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

对于ksqldb中的父级，我只需在ksqldb中的select中添加一个"join_field“：

  SELECT
    'parent' AS join_field, \
    ...

但我如何创造这个孩子呢？Elasticsearch期待这种格式：

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

我使用"io.confluent.connect.elasticsearch.ElasticsearchSinkConnector“将数据从ksqldb推送到elasticsearch。

Answer 1

它还没有实施。希望很快。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(name := 'child'，parent := parentid)作为join_field，\