flink cdc 1.19.1 https://nightlies.apache.org/flink/flink-cdc-docs-release-3.3/docs/get-started/quickstart/mysql-to-starrocks/ # 启动 # 所在的服务器是: 技术预演的操作 使用 start-flink-jobs.sh 进行启动 http://117.78.39.204:8081/ # 通过https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-mysql/3.3.0/flink-cdc-pipeline-connector-mysql-3.3.0.jar # 可以推测出: 相关的sink包在https://repo1.maven.org/maven2/org/apache/flink kafka的数据 https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-kafka/3.3.0/ mysql to kafka 需要用到的lib信息包括 # /data/soft/flink/flink-1.19.1/flink-1.19.1/flink-cdc-3.3.0/lib 中需要 flink-cdc-dist-3.3.0.jar flink-cdc-pipeline-connector-kafka-3.3.0.jar flink-cdc-pipeline-connector-mysql-3.3.0.jar # /data/soft/flink/flink-1.19.1/flink-1.19.1/lib 中需要添加 mysql-connector-j-8.0.32.jar # 执行如下语句将Mysql数据同步到Kafka bash bin/flink-cdc.sh mysql-to-kafka.yaml --flink-home=/data/soft/flink/flink-1.19.1/flink-1.19.1 # 访问地址 http://117.78.39.204:8081/#/job/running