Implement MySQL CDC in Apache SeaTunnel(Incubating)
MySQL CDC implementation is supported in Apache SeaTunnel, set up the MySQL CDC connector now.
If you’re trying Apache SeaTunnel for the first time, you can download it here: https://seatunnel.apache.org/download
Then set up the MySQL CDC connector:
Visit https://seatunnel.apache.org/docs/2.3.0/connector-v2/source/MySQL-CDC/ or https://github.com/apache/incubator-seatunnel/blob/dev/docs/en/connector-v2/source/MySQL-CDC.md to set up the MySQL CDC connector to run SQL queries against MySQL databases, including the user guide and configuration demo.
env {
# You can set engine configuration here
execution.parallelism = 1
job.mode = "STREAMING"
execution.checkpoint.interval = 5000
#execution.checkpoint.data-uri = "hdfs://localhost:9000/checkpoint"
}
source {
# This is a example source plugin **only for test and demonstrate the feature source plugin**
MySQL-CDC {
result_table_name = "fake"
parallelism = 1
server-id = 5656
port = 56725
hostname = "127.0.0.1"
username = "mysqluser"
password = "mysqlpw"
database-name = "inventory_vwyw0n"
table-name = "products"
base-url = "jdbc:mysql://localhost:56725"
}
}
transform {
}
sink {
console {
source_table_name="fake"
}
}
📌📌Welcome to fill out this survey to give your feedback on your user experience or just your ideas about Apache SeaTunnel:)