From b32455eb6a70f22c256c4cc927d649002528cefc Mon Sep 17 00:00:00 2001 From: Robert Yokota Date: Tue, 19 Dec 2023 10:54:54 -0800 Subject: [PATCH] Minor fix --- .../kafka/schemaregistry/client/MockSchemaRegistryClient.java | 2 +- 1 file changed, 1 insertion(+), 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 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();