小编Thr*_*ots的帖子

我在 kafka connect 中有一个发件箱 postgresql 表和 debezium 连接器，它根据表中添加的行创建 kafka 消息。

我面临的问题是消息格式。这是创建的消息值：

{
  "schema": {
    "type": "string",
    "optional": true,
    "name": "io.debezium.data.Json",
    "version": 1
  },
  "payload": "{\"foo\": \"bar\"}"
}

但是（因为消费者）我需要消息仅包含有效负载，如下所示：

{
  "\"foo\": \"bar\""
}

这是我的卡夫卡连接器配置的一部分：

"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__"

有没有办法在不创建自定义变压器的情况下实现这一目标？