0
Können AVRO-Schemas mit einem konfluenten Schema-Registrierungsdienst registriert werden?Registrieren des AVRO-Schemas mit dem konfluenten Schema registery
Per readme auf Github https://github.com/confluentinc/schema-registry
Jedes Beispiel wird ein JSON-Schema mit einem einzigen Feld und gibt ohne Namen.
Ich versuche, folgendes Schema zu Repository zu speichern, aber mit verschiedenen Varianten, die unterschiedliche Fehler bekommen.
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"}]}"}'
Oder
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
Ja. Absolut. Schauen Sie sich dieses Beispiel an: https://github.com/conflutinc/examples/blob/3.1.x/kafka-streams/src/main/java/io/confluent/examples/streams/WikipediaFeedAvroLambdaExample.java –
"mit anderen Varianten bekommen unterschiedliche Fehler ": Es würde helfen, wenn Sie diese Fehler in Ihre Frage einbeziehen würden. –