我想发送一个json到一个Kafka主题使用 Postman 。
在postman中，当发送以下json时，一切正常（kafka没有返回错误，并且当使用主题时，我可以看到正确的值）：

{
  "records": [
    {
        "key":"some_key",
      "value":"test"

    }
  ]
}

但是，当使用 schema 以及 payload 嵌入的：

{
  "schema": {
    "type": "struct",
    "fields": [
      {
        "type": "string",
        "optional": false,
        "field": "userid"
      },
      {
        "type": "string",
        "optional": false,
        "field": "regionid"
      },
      {
        "type": "string",
        "optional": false,
        "field": "gender"
      }
    ],
    "optional": false,
    "name": "ksql.users"
  },
  "payload": {
    "userid": "User_1",
    "regionid": "Region_5",
    "gender": "MALE"
  }
}

我得到以下答案：

{
    "error_code": 422,
    "message": "Unrecognized field: schema"
}

以下来源建议嵌入一个模式，因为jdbc接收器需要它：https://github.com/confluentinc/kafka-connect-jdbc/issues/609https://www.confluent.io/blog/kafka-connect-deep-dive-converters-serialization-explained/
在我的 sink-postgresql.properties 我设置：

value.converter=org.apache.kafka.connect.json.JsonConverter
value.converter.shemas.enable=true

key.converter.shemas.enable=true
key.converter=org.apache.kafka.connect.json.JsonConverter

我不知道为什么到目前为止还不起作用，一些帮助可能有用。
系统：ubuntu18.04融合平台postman 7.14