Details
-
Bug
-
Resolution: Unresolved
-
Minor
-
1.9.0.Final
-
None
-
False
-
None
-
False
-
- Create outbox table
- Create connector using transforms.outbox.table.expand.json.payload and JsonConverter
- Create record with a key with null value.
Description
What Debezium connector do you use and what version?
debezium/connect:1.9
What is the connector configuration?
{ "plugin.name": "pgoutput", "connector.class": "io.debezium.connector.postgresql.PostgresConnector", "database.hostname": "${file:/secrets/debezium.properties:postgres_hostname}", "database.port": "${file:/secrets/debezium.properties:postgres_port}", "database.user": "${file:/secrets/debezium.properties:postgres_user}", "database.password": "${file:/secrets/debezium.properties:postgres_password}", "database.dbname": "ticketing-service", "database.server.name": "ticketing-service", "table.include.list": "public.ticketing_outbox", "tombstones.on.delete": "false", "transforms": "outbox", "transforms.outbox.type": "io.debezium.transforms.outbox.EventRouter", "transforms.outbox.table.expand.json.payload": "true", "key.converter": "org.apache.kafka.connect.storage.StringConverter", "key.converter.schemas.enable": "false", "value.converter": "org.apache.kafka.connect.json.JsonConverter", "value.converter.schemas.enable": "false", "heartbeat.interval.ms": "60000", "heartbeat.action.query": "UPDATE public.ticketing_heartbeat SET updated_at = now();", "publication.autocreate.mode": "filtered" }
What is the captured database version and mode of depoyment?
docker-compose, postgres:13.4
What behaviour do you expect?
A null payload key should be present in the kafka events.
What behaviour do you see?
My outbox table has a jsonb payload column, I'm inserting a record similar to this one
{ "before": null, "after": { # lots of stuff } }
The produced event looks like this
{
"after": {
# lots of stuff
}
}
I need the "before" key to be in the event. Before I was using the Avro converter and the before key was present.
Do you see the same behaviour using the latest relesead Debezium version?
Yes