diff --git a/schemaregistry/serde/serde.go b/schemaregistry/serde/serde.go index 911070a24..c25ba9cfa 100644 --- a/schemaregistry/serde/serde.go +++ b/schemaregistry/serde/serde.go @@ -150,10 +150,13 @@ func (s *BaseSerializer) GetID(topic string, msg interface{}, info schemaregistr if err != nil { return -1, err } - _, err := s.Client.GetID(subject, info, false) + id, err = s.Client.GetID(subject, info, false) if err != nil { return -1, err } + if id != useSchemaID { + return -1, fmt.Errorf("failed to match schema ID (%d != %d)", id, useSchemaID) + } } else if useLatest { metadata, err := s.Client.GetLatestSchemaMetadata(subject) if err != nil {