使用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
1