未验证 提交 1ec153ad 编写于 作者: Y yukun 提交者: GitHub

[skip ci]Add comments for CreateProducer (#9517)

Signed-off-by: Nfishpenguin <kun.yu@zilliz.com>
上级 cc07fc5f
......@@ -34,6 +34,7 @@ func NewRmqClient(opts rocksmq.ClientOptions) (*rmqClient, error) {
return &rmqClient{client: c}, nil
}
// CreateProducer creates a producer for rocksmq client
func (rc *rmqClient) CreateProducer(options ProducerOptions) (Producer, error) {
rmqOpts := rocksmq.ProducerOptions{Topic: options.Topic}
pp, err := rc.client.CreateProducer(rmqOpts)
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册