目前有个需求想实现mysql到clickhouse的同步,当前负责到这块中间踩了很多坑特此记录一下。
jdk?8
seatunnel2.3.3版本
clickhouse22.1.12
5.7.37-log
export version="2.3.3"
wget "https://archive.apache.org/dist/incubator/seatunnel/${version}/apache-seatunnel-incubating-${version}-bin.tar.gz"
tar -xzvf "apache-seatunnel-incubating-${version}-bin.tar.gz"
etc/profile.d/seatunel.sh中配置自己的环境变量
1.在config下plugin_config配置所需连接器,按需下载,不需要的可以注释掉,也可以全部下载(在线的非常慢).
2.在bin目录下执行命令
./install-plugin.sh
去maven仓库下载,使用seatunnel那个版本就去下对应的那个版本
https://mvnrepository.com/artifact/io.zipkin.java/zipkin-storage-elasticsearch-http
这个很重要(同样去maven仓库下载)开始入门时网上好多都没有介绍这一步,导致我运行官方测试用例时一直报错。
v2.batch.config.template
在bin目录下执行
sh seatunnel.sh --config ../config/v2.batch.config.template -m local
控制台显示16行插入数据表示成功