Minor fix

confluentinc · Dec 19, 2023 · b32455e · b32455e
1 parent 01cc37a
commit b32455e
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/client/src/main/java/io/confluent/kafka/schemaregistry/client/MockSchemaRegistryClient.java b/client/src/main/java/io/confluent/kafka/schemaregistry/client/MockSchemaRegistryClient.java
@@ -352,7 +352,7 @@ public Collection<SubjectVersion> getAllVersionsById(int id) throws IOException,
           ParsedSchema schema = e.getValue().get(id);
           Map<ParsedSchema, Integer> schemaVersionMap = schemaToVersionCache.get(e.getKey());
           if (schemaVersionMap != null) {
-            int version = schemaToVersionCache.get(e.getKey()).get(schema);
+            int version = schemaVersionMap.get(schema);
             return Stream.of(new SubjectVersion(e.getKey(), version));
           } else {
             return Stream.empty();