commit 30f697e9aa66b5aadb8169ce2936b3b6f816a127
author Xiaojian Sun <sunxiaojian926@163.com> Fri Apr 21 10:15:48 2023 +0800
committer GitHub <noreply@github.com> Fri Apr 21 10:15:48 2023 +0800
tree 5dd82298dbc02b996667addf9b9286c8a43c6f43
parent 921cb9cdd18b1501d41ad9631607ffd843ec1675

[ISSUE #79] Fix CachedschemaRegistryClient.deleteSchema execution failed

Co-authored-by: xiaoyi <xiaojian.sxj@alibaba-inc.com>

client/src/main/java/org/apache/rocketmq/schema/registry/client/CachedSchemaRegistryClient.java

diff --git a/client/src/main/java/org/apache/rocketmq/schema/registry/client/CachedSchemaRegistryClient.java b/client/src/main/java/org/apache/rocketmq/schema/registry/client/CachedSchemaRegistryClient.java
index 8e87666..d884492 100644
--- a/client/src/main/java/org/apache/rocketmq/schema/registry/client/CachedSchemaRegistryClient.java
+++ b/client/src/main/java/org/apache/rocketmq/schema/registry/client/CachedSchemaRegistryClient.java
@@ -131,7 +131,10 @@
         String subjectFullName = String.format("%s/%s/%s", cluster, tenant, subject);
         schemaCacheBySubject.invalidate(subjectFullName);
         schemaCacheBySubjectAndVersion.invalidate(new SubjectAndVersion(cluster, tenant, subject, version));
-        subjectToVersion.get(subjectFullName).remove(version);
+
+        if (subjectToSchema.get(subjectFullName) != null) {
+            subjectToVersion.get(subjectFullName).remove(version);
+        }
 
         return restService.deleteSchema(cluster, tenant, subject, version);
     }