【文件属性】：
文件名称：postgres-cdc-flink:使用Debezium流式传输PostgreSQL CDC，并使用Flink使用状态流进行充实
文件大小：67KB
文件格式：ZIP
更新时间：2021-04-10 00:53:17
kafka stream flink debezium Java
使用Flink丰富Kafka流与另一个流
环境设定
安装PostgreSQL 11+
设置PostgreSQL以允许使用pgoutput将Debezium转换为CDC。 参考
在您的机器/集群上设置Apache Kafka（使用Kafka Connect）
从安装Debezium PostgreSQL连接器
运行Apache Kafka和Kafka Connect
在PostgreSQL中创建表transactions和customers （SQL文件）
使用请求主体向您的Kafka Connect REST接口创建POST请求，如下所示
{
" name " : " postgres_cdc " ,
" config " : {
" connector.class " : " io.debezium.connector.postgresql.PostgresCon
【文件预览】：
postgres-cdc-flink-main
----.gitignore(4KB)
----.project(939B)
----README.md(2KB)
----pom.xml(7KB)
----.github()
--------workflows()
----.vscode()
--------launch.json(826B)
--------settings.json(2B)
----LICENSE(11KB)
----sql()
--------tables.sql(2KB)
----src()
--------test()
--------main()
----.classpath(11KB)