我是新来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"}}
实现这一目标的最佳方式是什么?
暂无答案!
目前还没有任何答案,快来回答吧!