Apache Kafka Schema-Registry是一个用于存储并管理Kafka消息协议和模式的中央位置。但是有时候使用它时会出现问题。
一个常见的问题是在使用schema-registry的REST API时,注册模式会失败并返回错误消息“HTTP 422 Unprocessable Entity”。这通常是由于模式不符合兼容性检查而导致的。
以下是一个可能的解决方案,可以在此处的REST API调用中包含JSON payload:
curl -X POST -i -H "Content-Type: application/vnd.schemaregistry.v1+json" \
--data '{ "schema" : "{ \"type\": \"record\", \"name\": \"test\", \"fields\": [{\"name\":\"field\",\"type\":\"string\"}]}" }'\
http://localhost:8081/subjects/test/versions
该方法包括在JSON负载中定义了模式,以确保兼容性检查能够成功。
希望这可以帮助您解决Apache Kafka Schema-Registry问题。