I have an outbox postgresql table and debezium connector in kafka connect that creates kafka messages based on the added rows to the table.
The problem I am facing is with the message format. This is the created message value:
{
"schema": {
"type": "string",
"optional": true,
"name": "io.debezium.data.Json",
"version": 1
},
"payload": "{"foo": "bar"}"
}
But (because of consumer) I need the message to contain only the payload, like this:
{
""foo": "bar""
}
This is part of my kafka connector configuration:
"transforms": "outbox",
"transforms.outbox.type": "io.debezium.transforms.outbox.EventRouter",
"transforms.outbox.route.topic.replacement": "${routedByValue}",
"transforms.outbox.route.by.field": "aggregate_type",
"transforms.outbox.table.field.event.payload.id": "aggregate_id",
"transforms.outbox.table.fields.additional.placement": "payload_type:header:__TypeId__"
Is there any way to achieve this without creating custom transformer?
与恶龙缠斗过久,自身亦成为恶龙;凝视深渊过久,深渊将回以凝视…