我已经在Confluent中配置了一个PostgreSQL CDC连接器,该连接器连接到一个AWS RDS示例。
每个表中的消息都会流入主题,但JSON的结构是
然而,根据文档(具体地说,使用BEFORE、AFTER和OP字段),我预计会出现类似这样的结构
根据文件,我试着将REPLICA IDENTITY
设置为FULL
,但它仍然不起作用。
你知道我怎么才能得到这些田地吗?
我已经在Confluent中配置了一个PostgreSQL CDC连接器,该连接器连接到一个AWS RDS示例。
每个表中的消息都会流入主题,但JSON的结构是
然而,根据文档(具体地说,使用BEFORE、AFTER和OP字段),我预计会出现类似这样的结构
根据文件,我试着将REPLICA IDENTITY
设置为FULL
,但它仍然不起作用。
你知道我怎么才能得到这些田地吗?
1条答案
按热度按时间0qx6xfy61#
我发现我没有在高级配置中将After-State Only参数设置为
false
。