From 83dfbfb856b4e09790790f20ced783a79c67c72b Mon Sep 17 00:00:00 2001 From: yukun Date: Fri, 10 Dec 2021 10:04:33 +0800 Subject: [PATCH] [skip ci]Add comment for rocksmq reader (#13092) Signed-off-by: fishpenguin --- internal/util/rocksmq/client/rocksmq/reader_impl.go | 1 + 1 file changed, 1 insertion(+) diff --git a/internal/util/rocksmq/client/rocksmq/reader_impl.go b/internal/util/rocksmq/client/rocksmq/reader_impl.go index d075f4b910..de6ca26202 100644 --- a/internal/util/rocksmq/client/rocksmq/reader_impl.go +++ b/internal/util/rocksmq/client/rocksmq/reader_impl.go @@ -51,6 +51,7 @@ func newReader(c *client, readerOptions *ReaderOptions) (*reader, error) { return reader, nil } +//Topic return the topic name of the reader func (r *reader) Topic() string { return r.topic }