Use schema ID returned from GetID() (fixes confluentinc#848)

perdue · Oct 9, 2022 · e714a40 · e714a40
1 parent ac9817f
commit e714a40
Showing 1 changed file with 4 additions and 1 deletion.
diff --git 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 {