文件名称：postgres-cdc-flink:使用Debezium流式传输PostgreSQL CDC，并使用Flink使用状态流进行充实
文件大小：67KB
文件格式：ZIP
更新时间：2024-04-29 18:39:57
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)