Debezium Connector для PostgreSQL вводит \ в тему данные типа JSON - PullRequest
Новая
       57

Debezium Connector для PostgreSQL вводит \ в тему данные типа JSON

1 голос
/ 25 сентября 2019

Я новичок в kafka и хотел бы получить совет по этой проблеме.Я пытаюсь создать данные для одной из тем kafka из таблицы в postgres, один из столбцов имеет тип 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"}}

Каков наилучший способ достичь этого?

...