diff --git a/internal/util/mqclient/rmq_message.go b/internal/util/mqclient/rmq_message.go
index 2ebdaa9be6..d4bdafd4af 100644
--- a/internal/util/mqclient/rmq_message.go
+++ b/internal/util/mqclient/rmq_message.go
@@ -23,6 +23,7 @@ type rmqMessage struct {
 	msg rocksmq.Message
 }
 
+// Topic returns the topic name of rocksmq message
 func (rm *rmqMessage) Topic() string {
 	return rm.msg.Topic
 }