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

Reply via email to