Implement MySQL CDC in Apache SeaTunnel(Incubating)

Apache SeaTunnel
CodeX
Published in
1 min readFeb 16, 2023

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:)

--

--

Apache SeaTunnel
CodeX
Writer for

The next-generation high-performance, distributed, massive data integration tool.