From 7ae855ca818653144086f6ab07f9ca36c156458d Mon Sep 17 00:00:00 2001 From: Brent Perdue Date: Sun, 9 Oct 2022 12:00:02 -0400 Subject: [PATCH] Use schema ID returned from GetID() (fixes #848) --- schemaregistry/serde/serde.go | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) 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 {