Skip to content

Commit b454815

Browse files
authored
Merge pull request #3160 from confluentinc/revert-inmemory-cache-change
Revert recent change to in-memory cache
2 parents c7b2d0d + b169203 commit b454815

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

core/src/main/java/io/confluent/kafka/schemaregistry/storage/InMemoryCache.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -174,7 +174,7 @@ public void schemaDeleted(
174174
addToSchemaHashToGuid(schemaKey, schemaValue);
175175
for (SchemaReference ref : schemaValue.getReferences()) {
176176
QualifiedSubject refSubject = QualifiedSubject.qualifySubjectWithParent(
177-
tenant(), schemaKey.getSubject(), ref.getSubject(), true);
177+
tenant(), schemaKey.getSubject(), ref.getSubject());
178178
SchemaKey refKey = new SchemaKey(refSubject.toQualifiedSubject(), ref.getVersion());
179179
Map<String, Map<SchemaKey, Set<Integer>>> ctxRefBy =
180180
referencedBy.getOrDefault(tenant(), Collections.emptyMap());
@@ -226,7 +226,7 @@ public void schemaRegistered(
226226
addToSchemaHashToGuid(schemaKey, schemaValue);
227227
for (SchemaReference ref : schemaValue.getReferences()) {
228228
QualifiedSubject refSubject = QualifiedSubject.qualifySubjectWithParent(
229-
tenant(), schemaKey.getSubject(), ref.getSubject(), true);
229+
tenant(), schemaKey.getSubject(), ref.getSubject());
230230
SchemaKey refKey = new SchemaKey(refSubject.toQualifiedSubject(), ref.getVersion());
231231
Map<String, Map<SchemaKey, Set<Integer>>> ctxRefBy =
232232
referencedBy.computeIfAbsent(tenant(), k -> new ConcurrentHashMap<>());

0 commit comments

Comments
 (0)