mysql-to-kafka.yaml 示例
mysql-to-kafka.yaml 示例
source:
type: mysql
hostname: 10.0.0.5
port: 3306
username: cdc_ro
password: '***'
tables: app.orders, app.users
server-id: 5400-5404
server-time-zone: Asia/Shanghai
sink:
type: kafka
properties.bootstrap.servers: 10.0.0.6:9092
topic: mysql-to-kafka
pipeline:
name: mysql-to-kafka
parallelism: 2提交作业
提交作业
bin/flink-cdc.sh mysql-to-kafka.yaml管道属性随版本演进（3.0 与 3.1 的 sink 参数有差异），落库前对照所用版本的官方示例核对一遍。