class AvroSchemaRegistry::Client
Public Instance Methods
compatible?(subject, schema, version = 'latest', **params)
click to toggle source
Override to add support for additional params
# File lib/avro_schema_registry/client.rb, line 40 def compatible?(subject, schema, version = 'latest', **params) data = post("/compatibility/subjects/#{subject}/versions/#{version}", expects: [200, 404], body: { schema: schema.to_s }.merge!(params).to_json) data.fetch('is_compatible', false) unless data.key?('error_code') end
lookup_subject_schema(subject, schema)
click to toggle source
# File lib/avro_schema_registry/client.rb, line 10 def lookup_subject_schema(subject, schema) schema_object = if schema.is_a?(String) Avro::Schema.parse(schema) else schema end data = get("/subjects/#{subject}/fingerprints/#{schema_object.sha256_resolution_fingerprint.to_s(16)}") id = data.fetch('id') @logger.info("Found schema for subject `#{subject}`; id = #{id}") id end
register(subject, schema, **params)
click to toggle source
Override register to first check if a schema is registered by fingerprint Also, allow additional params to be passed to register.
# File lib/avro_schema_registry/client.rb, line 25 def register(subject, schema, **params) lookup_subject_schema(subject, schema) rescue Excon::Errors::NotFound register_without_lookup(subject, schema, **params) end
register_without_lookup(subject, schema, **params)
click to toggle source
# File lib/avro_schema_registry/client.rb, line 31 def register_without_lookup(subject, schema, **params) data = post("/subjects/#{subject}/versions", body: { schema: schema.to_s }.merge!(params).to_json) id = data.fetch('id') @logger.info("Registered schema for subject `#{subject}`; id = #{id}") id end