diff --git a/internal/util/rocksmq/client/rocksmq/consumer_impl.go b/internal/util/rocksmq/client/rocksmq/consumer_impl.go
index 57d7ae5c5a..0a9d5bcd48 100644
--- a/internal/util/rocksmq/client/rocksmq/consumer_impl.go
+++ b/internal/util/rocksmq/client/rocksmq/consumer_impl.go
@@ -90,6 +90,7 @@ func (c *consumer) Subscription() string {
 	return c.consumerName
 }
 
+// Topic returns the topic of the consumer
 func (c *consumer) Topic() string {
 	return c.topic
 }