debezium connector for postgresql引入了json类型的主题数据

nnsrf1az  于 2021-06-04  发布在  Kafka
关注(0)|答案(0)|浏览(237)

我是新来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-类型它Map到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"}}

实现这一目标的最佳方式是什么?

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题