diff --git a/internal/util/rocksmq/client/rocksmq/producer_impl.go b/internal/util/rocksmq/client/rocksmq/producer_impl.go
index 51586a4340..981a32d403 100644
--- a/internal/util/rocksmq/client/rocksmq/producer_impl.go
+++ b/internal/util/rocksmq/client/rocksmq/producer_impl.go
@@ -44,6 +44,7 @@ func newProducer(c *client, options ProducerOptions) (*producer, error) {
 	}, nil
 }
 
+// Topic returns the topic name of producer
 func (p *producer) Topic() string {
 	return p.topic
 }