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

confluentinc · Jan 12, 2023 · 32d864d · 32d864d
1 parent 393b43b
commit 32d864d
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 {