您可以在 cmd 的以下命令的帮助下首次注册您的 avro 架构
curl -X POST -i -H "Content-Type: application/vnd.schemaregistry.v1+json" \
--data '{"schema": "{\"type\": \"string\"}"}' \
http://localhost:8081/subjects/topic
您可以使用查看主题的所有版本
curl -X GET -i http://localhost:8081/subjects/topic/versions
要从融合模式注册表中存在的所有版本中查看完整的 Acro 模式,请使用以下命令,将以 json 格式显示模式
curl -X GET -i http://localhost:8081/subjects/topica/versions/1
Avro 模式注册是 Kafka 生产者的任务
在融合模式注册表中拥有模式后,您只需要将 avro 通用记录发布到特定的 kafka 主题,在我们的例子中是“主题”
Kafka 消费者:使用以下代码获取特定 Kafka 主题的最新模式
val schemaReg = new CachedSchemaRegistryClient(kafkaAvroSchemaRegistryUrl, 100)
val schemaMeta = schemaReg.getLatestSchemaMetadata(kafkaTopic + "-value")
val schema = schemaMeta.getSchema
val schema =new Schema.Parser().parse(schema)
以上将用于获取模式,然后我们可以使用融合来解码来自 kafka 主题的记录。