diff --git a/internal/util/rocksmq/client/rocksmq/producer_impl.go b/internal/util/rocksmq/client/rocksmq/producer_impl.go
index 9bf4e422d3..51586a4340 100644
--- a/internal/util/rocksmq/client/rocksmq/producer_impl.go
+++ b/internal/util/rocksmq/client/rocksmq/producer_impl.go
@@ -28,6 +28,7 @@ type producer struct {
 	topic string
 }
 
+// newProducer creates a rocksmq producer from options
 func newProducer(c *client, options ProducerOptions) (*producer, error) {
 	if c == nil {
 		return nil, newError(InvalidConfiguration, "client is nil")