GitHub - yhyyz/emr-flink-cdc · GitHub

Name		Name	Last commit message	Last commit date
Latest commit History 11 Commits
src/main		src/main
.gitignore		.gitignore
.java-version		.java-version
README.md		README.md
pom.xml		pom.xml

Repository files navigation

Flink CDC DataStream API

MySQLCDC

Flink MySQL CDC消费数据发送到Kafka,DataStream API

kafka2hudi

Flink 消费Kafka CDC数据，并行写到多个Hudi表, 注意这个例子中，库表写死了。使用时可以自己调整

About

No description, website, or topics provided.

Report repository

Releases

Packages

Contributors

Languages