postgres cdc flink:使用Debezium流式传输PostgreSQL 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