关于canal与es8

来源:12-5 canal索引构建进阶(5)

慕用8523549

2022-04-11

目前我用的ES为8.0.0。canal1.1.5。
我现在跟着步骤,将canal.adapter增加了es8的模块,修改对应的pom.xml文件,但问题是:
adapter源码中实现的代码是以high-level与 transport包为基础,而es8正好缺这两个的包,只有elasticsearch-rest-client:8.0.0。用“8.0.0-alpha2”版末又不兼容。

我要怎么办?如何用代阶包,实现数据etl?

写回答

1回答

龙虾三少

2022-04-11

最新版本的目前还没有兼容

0
1
慕用8523549
我修改的问题方式,我其实想问:如何用elasticsearch-rest-client:8.0.0,完成etl? 其实就是要修改“ESConnection.java”这个包里面的代码: 一、 GetMappingsRequest request = new GetMappingsRequest(); request.indices(index); GetMappingsResponse response = restHighLevelClient.indices() .getMapping(request, RequestOptions.DEFAULT); mappings = response.mappings(); 二、 restHighLevelClient.search(searchRequest, RequestOptions.DEFAULT); 三、 restHighLevelClient.bulk(bulkRequest, RequestOptions.DEFAULT);
2022-04-11
共1条回复

ES7+Spark 构建高匹配度搜索服务+千人千面推荐系统

ElasticSearch实现高相关性搜索,Spark MLlib实现个性化推荐

1384 学习 · 559 问题

查看课程