2016-11-21 86 views
0

AVRO模式可以使用匯合模式註冊表服務註冊嗎?使用匯合模式註冊表註冊AVRO模式

作爲每自述在github https://github.com/confluentinc/schema-registry

每個例子使用具有單個字段和類型JSON模式沒有任何名稱。

我想存儲以下架構到存儲庫,但不同的變體得到不同的錯誤。

curl -X POST -H "Content-Type: application/vnd.schemaregistry.v1+json" --data '{"schema": "{"type": "record","name": "myrecord","fields": [{"name": "serialization","type": "string"},{"name": "compression","type": "string"},{"name": "encoding","type": "string"},{"name": "data","type": "string"}]}"}' 

或者

curl -X POST -H "Content-Type: application/vnd.schemaregistry.v1+json" --data '{"schema": \"{\"type\": \"record\",\"name\": \"myrecord\",\"fields\": [{\"name\": \"data\",\"type\": \"string\"}]}\"}' http://localhost:8081/subjects/Kafka-key/versions 
+0

是的。絕對。 查看此示例:https://github.com/confluentinc/examples/blob/3.1.x/kafka-streams/src/main/java/io/confluent/examples/streams/WikipediaFeedAvroLambdaExample.java –

+0

「with different變體得到不同的錯誤「:如果你真的在你的問題中包含這些錯誤,這將有所幫助。 –

回答

0

Avro的模式可以使用卡夫卡使用以下命令

curl -X POST -i -H "Content-Type: application/vnd.schemaregistry.v1+json" --data '{"schema": "{\"type\": \"record\",\"name\": \"myrecord\",\"fields\": [{\"name\": \"serialization\",\"type\": \"string\"},{\"name\": \"compression\",\"type\": \"string\"},{\"name\": \"encoding\",\"type\": \"string\"},{\"name\": \"data\",\"type\": \"string\"}]}"}' http://localhost:8081/subjects/Kafka-key/versions 

你缺少一些PARAMS註冊。

您可以使用SchemaRegistryHelper來獲取任何id的模式以反序列化數據。