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

[skip ci]Add comments for rocksmq producer_impl (#10695)

Signed-off-by: Nfishpenguin <kun.yu@zilliz.com>
上级 648608d8
......@@ -57,6 +57,7 @@ func (p *producer) Send(message *ProducerMessage) (UniqueID, error) {
return ids[0], nil
}
// Close destroy the topic of this producer in rocksmq
func (p *producer) Close() {
err := p.c.server.DestroyTopic(p.topic)
if err != nil {
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册