diff --git a/internal/util/mqclient/rmq_reader.go b/internal/util/mqclient/rmq_reader.go
index acd1ccff7b..db6d791626 100644
--- a/internal/util/mqclient/rmq_reader.go
+++ b/internal/util/mqclient/rmq_reader.go
@@ -12,6 +12,7 @@ type rmqReader struct {
 	r rocksmq.Reader
 }
 
+// Topic returns the topic name of a reader
 func (rr *rmqReader) Topic() string {
 	return rr.r.Topic()
 }