proto: fix nil deref

birdayz · Aug 5, 2019 · 4a4dc72 · 4a4dc72
1 parent 8abb01e
commit 4a4dc72
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/cmd/kaf/consume.go b/cmd/kaf/consume.go
@@ -236,6 +236,9 @@ func protoDecode(b []byte, _type string) ([]byte, error) {
 	}
 
 	dynamicMessage := reg.MessageForType(_type)
+	if dynamicMessage == nil {
+		return b, nil
+	}
 
 	dynamicMessage.Unmarshal(b)