Kettle ES-Bulk-Insert 组件二开记录(基于 Kettle 9.2)
TODO: 待改造,目前这种可以配置变量的地方却无法配置变量(不识别,只能写死),之后尝试改下。 背景目前 Kettle 最新的版本是 9.2,但是 ES 仅支持到 6.4.2,而且也无法配置用户名和密码还有 schema,所以需要对 es-bulk-insert 组件改造下。 下载源码Kettle GitHub 源码地址 注意:有些包可能国内网络下载不下来,而且国内镜像也没有,就需要单独去想办法了,有人需要的话我会把包发出来。 主要改两个类 ElasticSearchBulk ElasticSearchBulkDialog 前者是业务数据执行需要的,后者是那个组件框需要的,比如你点 Test,就会调用这个类的 test 方法。 首先需要改 pom 文件,改成需要的版本 其次是这些在高版本中弃用的类和方法 在 Elastic 官网中也给出了对应的替代方法:官方迁移指南 ElasticSearchBulk 类的修改如下1234567891011121314151617181920212223242526272829303132333435363738394...
