diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/schema/SchemaRegistryServiceImpl.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/schema/SchemaRegistryServiceImpl.java index 26be4c621ab22..c68013769d1f0 100644 --- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/schema/SchemaRegistryServiceImpl.java +++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/schema/SchemaRegistryServiceImpl.java @@ -135,11 +135,14 @@ public CompletableFuture 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; }); } })