有看到官网介绍,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 } }