Search code examples
postgresqlapache-kafkaapache-kafka-connectdebeziumcdc

Fields missing from Kafka message using Debezium PostgreSQL CDC Connector

I have configured a PostgreSQL CDC Connector in Confluent, which is connected to an AWS RDS instance.

The messages from each table are being streamed into the topics but the structure for the JSON is

Current JSON structure

However, I was expecting something like this structure according to the docs (specifically with the before, after, and op fields)

Expected structure

I have tried setting the REPLICA IDENTITY to FULL, according to the docs, but it's still not working.

Any idea how I can get these fields?

Solution

  • Figured out I was missing setting the after-state only parameter in Advanced Configuration to false.