Revert recent change to in-memory cache

confluentinc · Jun 26, 2024 · b169203 · b169203
1 parent c7b2d0d
commit b169203
Showing 1 changed file with 2 additions and 2 deletions.
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
@@ -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<String, Map<SchemaKey, Set<Integer>>> 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<String, Map<SchemaKey, Set<Integer>>> ctxRefBy =
           referencedBy.computeIfAbsent(tenant(), k -> new ConcurrentHashMap<>());