Optimised

nikam14 · Sep 24, 2024 · c30ec3d · c30ec3d
1 parent f8f1d69
commit c30ec3d
Showing 1 changed file with 7 additions and 4 deletions.
diff --git a/...oker/src/main/java/org/apache/pulsar/broker/service/schema/SchemaRegistryServiceImpl.java b/...oker/src/main/java/org/apache/pulsar/broker/service/schema/SchemaRegistryServiceImpl.java
@@ -135,11 +135,14 @@ public CompletableFuture<SchemaAndMetadata> getSchema(String schemaId, SchemaVer
                                 .thenApply(Functions::schemaInfoToSchema)
                                 .thenApply(schema -> new SchemaAndMetadata(schemaId, schema, stored.version))
                                 .thenApply((schema) -> {
-                                    if (schema != null && schema.schema.isDeleted()) {
-                                        return null;
-                                    } else {
-                                        return schema;
+                                    if(version == SchemaVersion.Latest){
+                                        if (schema != null && schema.schema.isDeleted()) {
+                                            return null;
+                                        } else {
+                                            return schema;
+                                        }
                                     }
+                                    return schema;    
                                 });
                     }
                 })