1
gabon 209 天前 via iPhone
datax 应该是可以的,就是不知道满不满足你的轻量需求
|
2
potatowish 209 天前 via iPhone
debezium 可以用嵌入式的引擎,不上 kafaka connect 也行。还可以试试 flink cdc ,直接用本地集群
|
3
Variazioni OP @gabon 需要实时同步。datax 好像做不到?
|
4
Variazioni OP @potatowish flink cdc 好像只支持到 es7 。我这边需要同步到 es8 ,很难受。
debezium 使用嵌入式引擎同步到 es 有 demo 么?网上找了半天也没找到。 |
5
potatowish 201 天前 via iPhone
@Variazioni es connector 支持 7.x 和更高版本,连接器用 elasticsearch-7 ,参考这个基于 table api 的 demo: https://nightlies.apache.org/flink/flink-cdc-docs-release-3.0/zh/docs/connectors/legacy-flink-cdc-sources/tutorials/build-streaming-etl-tutorial/
|
6
Variazioni OP @potatowish 感谢。flink cdc 挺好用的。就决定用它了
|