-
使用Debezium通过流式处理将PostgreSQL CDC数据传输，并运用Flink的状态流进行数据丰富，项目名为postgres-cdc-flink
资源介绍
使用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