diff --git a/internal/util/mqclient/pulsar_reader.go b/internal/util/mqclient/pulsar_reader.go
index 6d496b5dc2..fe5b0a1c93 100644
--- a/internal/util/mqclient/pulsar_reader.go
+++ b/internal/util/mqclient/pulsar_reader.go
@@ -10,6 +10,7 @@ type pulsarReader struct {
 	r pulsar.Reader
 }
 
+// Topic returns the topic of pulsar reader
 func (pr *pulsarReader) Topic() string {
 	return pr.r.Topic()
 }