The only change that was made was in the register-postgres.json file to enable the json expan functionality: { "connector.class" : "io.debezium.connector.postgresql.PostgresConnector" , "tasks.max" : "1" , "database.hostname" : "service-db" , "database.port" : "5432" , "database.user" : "servicedb" , "database.password" : "servicedb" , "database.dbname" : "servicedb" , "database.server.name" : "servicedb" , "schema.include.list" : " public " , "table.include.list" : " public .outbox" , "tombstones.on.delete" : " false " , "transforms" : "outbox" , "transforms.outbox.type" : "io.debezium.transforms.outbox.EventRouter" , "transforms.outbox.table.expand.json.payload" : " true " , "transforms.outbox.route.topic.replacement" : "${routedByValue}.events" }