diff --git a/core/src/main/java/io/confluent/kafka/schemaregistry/storage/InMemoryCache.java b/core/src/main/java/io/confluent/kafka/schemaregistry/storage/InMemoryCache.java index e714ad3b92e..4c4c08ad469 100644 --- a/core/src/main/java/io/confluent/kafka/schemaregistry/storage/InMemoryCache.java +++ b/core/src/main/java/io/confluent/kafka/schemaregistry/storage/InMemoryCache.java @@ -174,7 +174,7 @@ public void schemaDeleted( addToSchemaHashToGuid(schemaKey, schemaValue); for (SchemaReference ref : schemaValue.getReferences()) { QualifiedSubject refSubject = QualifiedSubject.qualifySubjectWithParent( - tenant(), schemaKey.getSubject(), ref.getSubject(), true); + tenant(), schemaKey.getSubject(), ref.getSubject()); SchemaKey refKey = new SchemaKey(refSubject.toQualifiedSubject(), ref.getVersion()); Map>> ctxRefBy = referencedBy.getOrDefault(tenant(), Collections.emptyMap()); @@ -226,7 +226,7 @@ public void schemaRegistered( addToSchemaHashToGuid(schemaKey, schemaValue); for (SchemaReference ref : schemaValue.getReferences()) { QualifiedSubject refSubject = QualifiedSubject.qualifySubjectWithParent( - tenant(), schemaKey.getSubject(), ref.getSubject(), true); + tenant(), schemaKey.getSubject(), ref.getSubject()); SchemaKey refKey = new SchemaKey(refSubject.toQualifiedSubject(), ref.getVersion()); Map>> ctxRefBy = referencedBy.computeIfAbsent(tenant(), k -> new ConcurrentHashMap<>());