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 index 2128916f009..8bae6102fee 100644 --- 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 getAllVersionsById(int id) throws IOException, ParsedSchema schema = e.getValue().get(id); Map 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();