Search code examples
javaapache-kafkaavro

Avro schema versioning

Sorry this is a beginner AVRO question.

My Java microservice takes a payload request which has a schema version element, there can be a number of different versions of that payload each with a slightly different format. Is it possible to do a lookup against the AVRO schema registry using that version number then use that schema to validate the received payload.

Is this a valid and possible AVRO use case?

The intention then is to process this data in the Java microservice some more before sending on-wards.

Maybe AVRO is not the correct technology, but please advise if otherwise.

Solution

  • lookup against the AVRO schema registry using that version number

    The Avro schema ID in the registry is an incrementing number, not something which your data is really indexable by.

    I think what you're looking for is just a version ID, which the Confluent Avro Schema Registry supports by 

    GET /subjects/:name/versions/:id