diff --git a/plugin/storage/kafka/unmarshaller.go b/plugin/storage/kafka/unmarshaller.go
index 140b85bb771..d19b7181914 100644
--- a/plugin/storage/kafka/unmarshaller.go
+++ b/plugin/storage/kafka/unmarshaller.go
@@ -46,7 +46,7 @@ func (h *ProtobufUnmarshaller) Unmarshal(msg []byte) (*model.Span, error) {
 // JSONUnmarshaller implements Unmarshaller
 type JSONUnmarshaller struct{}
 
-// NewJSONUnmarshaller constructs a ProtobufUnmarshaller
+// NewJSONUnmarshaller constructs a JSONUnmarshaller
 func NewJSONUnmarshaller() *JSONUnmarshaller {
 	return &JSONUnmarshaller{}
 }