向Kafka Schema Registry提交Avro Schema时出现空Schema错误

问题原因分析 #

出现{"error_code":42201,"message":"Empty schema"}错误，核心原因有两个：

• 提交的请求格式不符合Schema Registry的API规范
• 文件名/路径不匹配导致curl无法读取到Schema内容

解决方案步骤 #

1. 修正Schema文件的格式 #

Schema Registry的POST接口要求请求体是包含schema字段的JSON对象，而非直接提交Avro Schema本身。你需要将原Avro Schema包装到schema字段中（注意Schema内容需转义为JSON字符串），保存为JSON文件（比如transaction-schema.json）：

{
  "schema": "{\"type\": \"record\", \"name\": \"Transaction\", \"namespace\": \"com.prxm\", \"fields\": [{\"name\": \"Timestamp\", \"type\": \"Date\"}, {\"name\": \"Price\", \"type\": \"double\"}, {\"name\": \"Qty\", \"type\": \"int\"}, {\"name\": \"Name\", \"type\": \"string\"}]}"
}

如果需要更易读的编辑格式，也可以写成（保持转义的双引号）：

{
  "schema": "{
    \"type\": \"record\",
    \"name\": \"Transaction\",
    \"namespace\": \"com.prxm\",
    \"fields\": [
      {\"name\": \"Timestamp\", \"type\": \"Date\"},
      {\"name\": \"Price\", \"type\": \"double\"},
      {\"name\": \"Qty\", \"type\": \"int\"},
      {\"name\": \"Name\", \"type\": \"string\"}
    ] 
  }"
}

2. 确保文件名与命令匹配 #

你之前将Schema保存为.avsc文件，但curl命令中指定的是transaction-schema.json，请二选一调整：

• 把.avsc文件重命名为transaction-schema.json，并按上述格式修正内容
• 修改curl命令中的文件名，比如原文件是transaction.avsc，命令改为：

curl -X POST -H "Content-Type: application/vnd.schemaregistry.v1+json" --data @transaction.avsc http://localhost:8081/subjects/transaction-value/versions

3. 验证文件可正常读取 #

在执行curl命令前，先通过cat transaction-schema.json（或对应文件名）确认文件内容正确，且当前终端目录与文件所在目录一致，避免路径错误。

4. 测试修正后的提交命令 #

执行调整后的curl命令，即可成功将Schema提交到Registry。

额外检查项 #

• 确认Schema Registry服务正常运行：执行curl http://localhost:8081/subjects，若返回现有subject列表则服务正常
• 检查Avro Schema语法：你当前定义的Schema语法合法，Date是Avro支持的类型，后续若出现数据兼容性问题再针对性调整

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