From da4931810fb9236bbb61cb610068d323648a90c8 Mon Sep 17 00:00:00 2001 From: yukun Date: Thu, 16 Dec 2021 20:43:34 +0800 Subject: [PATCH] [skip ci]Add comment for rocksmq producer client (#13533) Signed-off-by: fishpenguin --- internal/util/rocksmq/client/rocksmq/producer_impl.go | 1 + 1 file changed, 1 insertion(+) 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")