From 902f6111ab9d1b141f5d83690155962d1db7e366 Mon Sep 17 00:00:00 2001 From: yukun Date: Thu, 16 Dec 2021 20:45:27 +0800 Subject: [PATCH] [skip ci]Add comment for rocksmq producer client (#13534) 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 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 }