我想从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。
1条答案
按热度按时间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,\