Kafka cp-server无法在代理端验证消息

lmyy7pcs  于 2023-01-25  发布在  Apache
关注(0)|答案(1)|浏览(102)

我需要在经纪人端验证消息。

  • 我运行cp-server(仅运行cp-all-in-one合成文件)。
  • 创建了一个主题
  • confluent.value.schema.validation设置为真
  • 已注册架构(JSON)
  • 产生了一条信息

它总是失败。为什么验证失败?我应该改变配置吗?
模式:

{
  "$id": "http://example.com/models/data-item-definition.json",
  "$schema": "https://json-schema.org/draft/2020-12/schema",
  "description": "test data item 1",
  "properties": {
    "array_val": {
      "items": {
        "type": "string"
      },
      "type": [
        "array",
        "null"
      ]
    },
    "int_val": {
      "type": "integer"
    },
    "string_val": {
      "type": "string"
    }
  },
  "required": [
    "string_val",
    "int_val"
  ],
  "title": "data item",
  "type": "object"
}

留言:

{
  "string_val": "text",
  "int_val": 10,
  "array_val": ["one", "two", "three"]
}
aoyhnmkz

aoyhnmkz1#

一个问题是,如果confluent.value.schema.validation为真,那么为了生成消息,我们需要在开始时发送一个魔术字节和一个模式ID。
请参见导线格式。

相关问题