时间戳

首页 > 解决方案 > Debezium Connector for PostgreSQL 在 JSON 类型的主题数据中引入 \

json - Debezium Connector for PostgreSQL 在 JSON 类型的主题数据中引入 \

问题描述

我是kafka的新手，想就这个问题得到一些建议。我正在尝试从 postgres 中的表中为 kafka 主题之一生成数据，其中一列的类型为 json，它在模式文件（.avsc）中定义如下：

{
              "name": "details",
              "type": [
                "null",
                {
                  "type": "string",
                  "connect.version": 1,
                  "connect.name": "io.debezium.data.Json"
                }
              ],
              "default": null
            }

根据https://debezium.io/documentation/reference/0.9/connectors/postgresql.html#data-types它映射到 kafka 连接器的字符串数据类型。db 列包含如下数据：

{"type":"User","id":"123","attributes":{"id":"123","state":"active"}}

但是该主题会产生这样的结果：

{\"type\":\"User\",\"id\":\"123\",\"attributes\":{\"id\":\"123\",\"state\":\"active\"}}

我希望将其生成为与传递的字符串相同的字符串，而没有\. 因此，该主题的预期输出流应该类似于：

{"type":"User","id":"123","attributes":{"id":"123","state":"active"}}

实现它的最佳方法是什么？

标签： jsonapache-kafkaapache-kafka-connectdebezium

解决方案

推荐阅读