2016-11-21 1 views
0

AVRO 스키마를 합류 스키마 등록 서비스에 등록 할 수 있습니까? GitHub의 https://github.com/confluentinc/schema-registry합치적인 스키마 등록으로 AVRO 스키마 등록

모든 예에 대한 추가 정보 사항에 따라

은 이름없이 하나의 필드와 유형으로 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

" 변종은 다른 오류를 얻습니다. ": 실제로 이러한 오류를 질문에 포함하면 도움이됩니다. –

답변

0

브로 스키마는 일부 PARAMS 누락

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 

명령

아래 사용 카프카를 사용하여 등록 할 수 있습니다.

SchemaRegistryHelper를 사용하여 모든 ID의 스키마를 가져 와서 데이터를 deserialize 할 수 있습니다.

관련 문제