lib/field_struct/avro_schema/kafka/schema_registry.rb
# Check if a schema exists. Returns nil if not found.
Check if a schema exists. Returns nil if not found.
Check if a schema exists . Returns nil if not found .
def check(subject, schema)
          response = post "/subjects/#{subject}",
                          expects: [200, 404],
                          body: { schema: schema.to_s }
          data = response.to_json
          data unless data.key?('error_code')
        end
def check ( subject , schema ) response = post "/subjects/#{subject}" , expects : [ 200 , 404 ] , body : { schema : schema . to_s } data = response . to_json data unless data . key? ( 'error_code' ) end
Check if a schema exists.
Check if a schema exists .
subject
schema