有看到官网介绍,seatunnel支持整库同步,但我在实际使用过程中,没有找到关于整库同步的使用示例,根据官网的Source、Sink的介绍,自己写了一个MySQL
to MySQL的整库同步配置,但是运行报错。我的场景需求是,实现MySQL库的整库同步到另一个MySQL实例的数据库。
env {
parallelism = 1
job.mode = "STREAMING"
checkpoint.interval = 10000
}
source {
MySQL-CDC {
base-url = "jdbc:mysql://localhost:3306/test1"
username = "root"
password = "123456"
database-names = ["test1"]
startup.mode = "initial"
}
}
sink {
jdbc {
url =
"jdbc:mysql://localhost:3306/test2?useUnicode=true&characterEncoding=UTF-8&rewriteBatchedStatements=true"
driver = "com.mysql.cj.jdbc.Driver"
user = "root"
password = "123456"
# Automatically generate sql statements based on database table names
generate_sink_sql = true
database = test2
}
}