使用Debezium PostgreSQL CDC连接器的Kafka消息中缺少字段

juud5qan  于 2022-10-15  发布在  PostgreSQL
关注(0)|答案(1)|浏览(154)

我已经在Confluent中配置了一个PostgreSQL CDC连接器,该连接器连接到一个AWS RDS示例。
每个表中的消息都会流入主题,但JSON的结构是

然而,根据文档(具体地说,使用BEFOREAFTEROP字段),我预计会出现类似这样的结构

根据文件,我试着将REPLICA IDENTITY设置为FULL,但它仍然不起作用。
你知道我怎么才能得到这些田地吗?

0qx6xfy6

0qx6xfy61#

我发现我没有在高级配置中将After-State Only参数设置为false

相关问题