diff --git a/internal/util/mqclient/pulsar_reader.go b/internal/util/mqclient/pulsar_reader.go
index fe5b0a1c93..85a8029772 100644
--- a/internal/util/mqclient/pulsar_reader.go
+++ b/internal/util/mqclient/pulsar_reader.go
@@ -6,6 +6,7 @@ import (
 	"github.com/apache/pulsar-client-go/pulsar"
 )
 
+// pulsarReader contains a pulsar reader
 type pulsarReader struct {
 	r pulsar.Reader
 }