[rocketmq-schema-registry] branch main updated: Fix avro parse NPE (#51)

[karp]

This is an automated email from the ASF dual-hosted git repository.

karp pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/rocketmq-schema-registry.git


The following commit(s) were added to refs/heads/main by this push:
     new d783ba3  Fix avro parse NPE (#51)
d783ba3 is described below

commit d783ba3f79487fb40bbaf33679d781a1a54d0ff4
Author: wangfan <42178996+ferr...@users.noreply.github.com>
AuthorDate: Tue Aug 30 14:32:53 2022 +0800

    Fix avro parse NPE (#51)
---
 .../apache/rocketmq/schema/registry/common/dto/GetSchemaResponse.java | 4 ++++
 1 file changed, 4 insertions(+)

diff --git 
a/common/src/main/java/org/apache/rocketmq/schema/registry/common/dto/GetSchemaResponse.java
 
b/common/src/main/java/org/apache/rocketmq/schema/registry/common/dto/GetSchemaResponse.java
index a8ab363..6e6ef36 100644
--- 
a/common/src/main/java/org/apache/rocketmq/schema/registry/common/dto/GetSchemaResponse.java
+++ 
b/common/src/main/java/org/apache/rocketmq/schema/registry/common/dto/GetSchemaResponse.java
@@ -75,6 +75,10 @@ public class GetSchemaResponse extends BaseDto {
 
     private List<Field> parse(String schemaIdl) {
         Schema schema = new Schema.Parser().parse(schemaIdl);
+        if (schema.getType() != Schema.Type.RECORD) {
+            return null;
+        }
+
         return schema.getFields().stream().map(field -> {
             String type = field.schema().getType().getName();
             // ["null", "double"] represent this field is nullable