apache-kafka - 在架构注册表中存储 Avro 架构

Question

我正在使用 Confluent 的 JDBC 连接器以 Avro 格式将数据发送到 Kafka。我需要将此架构存储在架构注册表中，但我不确定它接受什么格式。我已阅读文档 here ，但它没有提到太多。

我已经尝试过这个(获取 Avro 输出并将其粘贴 - 对于一个 int 和一个字符串字段):

curl -X POST -H "Content-Type: application/vnd.schemaregistry.v1+json"     --data '{"type":"struct","fields":[{"type":"int64","optional":true,"field":"id"},{"type":"string","optional":true,"field":"serial"}],"optional":false,"name":"test"}' http://localhost:8081/subjects/view/versions

但我收到错误:{"error_code":422,"message":"Unrecognized field: type"}

Answer 1

您以 JSON 形式提供的架构应以“架构”键开头。您提供的实际模式将是键值 架构 .

所以你的请求应该是这样的:

 curl -X POST -H "Content-Type: application/vnd.schemaregistry.v1+json"     --data '{"schema" : "{\"type\":\"string\",\"fields\":[{\"type\":\"int64\",\"optional\":true,\"field\":\"id\"},{\"type\":\"string\",\"optional\":true,\"field\":\"serial\"}],\"optional\":false,\"name\":\"test\"}"}' http://localhost:8081/subjects/view/versions

我对命令做了另外两个更改:

我已经转义了 的值中的每个双引号架构 key 。

我已将结构数据结构更改为字符串。我不确定为什么它不采用复杂的结构。

查看他们如何为模式建模 here ，用于文档中描述的第一个 POST 请求。