使用ksqlDB创建流时遇EmptySchema不兼容错误求助

ksqlDB的Schema兼容性检查不支持**空Schema（EmptySchema）**作为流/表的值Schema，尽管org.everit.json.schema工具验证该Schema有效，但ksqlDB对可用于流/表的Schema有额外限制——要求值Schema必须定义至少一个可解析的字段或合法的根类型（如object/array），空Schema不在允许范围内。

• 修改目标Schema（ID 434）：
  登录Schema Registry，将ID为434的JSON Schema修改为包含至少一个字段的结构，即使是可选字段也可以。例如：

  {
    "type": "object",
    "properties": {
      "placeholder": { "type": "string", "default": "" }
    },
    "additionalProperties": true
  }
  

  这样既满足ksqlDB的Schema校验要求，又不会影响现有数据的兼容性（如果设置additionalProperties: true，原有无值的消息仍可被解析）。

• 调整流定义，不使用Schema Registry的值Schema：
  如果业务场景中确实不需要消息体（值），可以修改CREATE STREAM语句，跳过Schema Registry的关联：

  CREATE STREAM valid_deals (
      dealId BIGINT KEY
  ) WITH (
      KAFKA_TOPIC='valid_deals',
      PARTITIONS=4,
      REPLICAS=3,
      VALUE_FORMAT='NONE' -- 部分旧版本ksqlDB需用VALUE_FORMAT='BYTES'
  );
  

  这种方式下，ksqlDB会忽略消息的值部分，只处理KEY字段，无需依赖Schema Registry的Schema。

• 检查Schema Registry的Schema规范：
  确认ID 434的Schema是否符合Confluent Schema Registry对JSON Schema的要求——根类型必须是object或array，避免使用空Schema这类特殊类型。即使第三方工具验证通过，Confluent的实现可能有更严格的限制。

内容的提问来源于stack exchange，提问作者andresmonc