0

我正在尝试生成 AVRO/JSONSCHEMA 记录以融合云 REST 代理。自我管理的 REST 代理服务器已开始指向融合云,请参阅此文档。

我能够征集主题、生成 JSON 记录和消费者 JSON 记录。但是,每当我尝试涉及模式注册表,即 AVRO 记录或 JSONSCHEMA 记录生产时,它都会抛出 40801 错误。

对于生成记录,我参考了 REST 代理快速入门

REST 通话详情:

POST /topics/new-tweet HTTP/1.1
Host: <aws-hostname>:8082
Accept: application/vnd.kafka.v2+json
Content-Type: application/vnd.kafka.avro.v2+json
Cache-Control: no-cache
Postman-Token: c97b6f48-f68e-f114-63d8-c2389ffd77f0

{"value_schema": "{\"type\": \"record\", \"name\": \"User\", \"fields\": [{\"name\": \"name\", \"type\": \"string\"}]}", "records": [{"value": {"name": "testUser"}}]}

错误详情:

{
    "error_code": 40801,
    "message": "Error when registering schema. format = AVRO, subject = new-tweet-value, schema = {\"type\":\"record\",\"name\":\"User\",\"fields\":[{\"name\":\"name\",\"type\":\"string\"}]}"
}
4

0 回答 0