diff --git a/internal/util/mqclient/pulsar_client.go b/internal/util/mqclient/pulsar_client.go
index 10b85ad8b3..cf8f3ffb05 100644
--- a/internal/util/mqclient/pulsar_client.go
+++ b/internal/util/mqclient/pulsar_client.go
@@ -55,6 +55,7 @@ func (pc *pulsarClient) CreateProducer(options ProducerOptions) (Producer, error
 	return producer, nil
 }
 
+// CreateReader creates a pulsar reader instance
 func (pc *pulsarClient) CreateReader(options ReaderOptions) (Reader, error) {
 	opts := pulsar.ReaderOptions{
 		Topic:                   options.Topic,