From 490f8b50e1207838e51b5bde6bfe3c3c9b7613d3 Mon Sep 17 00:00:00 2001 From: yukun Date: Wed, 8 Dec 2021 20:43:24 +0800 Subject: [PATCH] [skip ci]Add comment for rocksmq reader (#13013) Signed-off-by: fishpenguin --- internal/util/mqclient/rmq_reader.go | 1 + 1 file changed, 1 insertion(+) diff --git a/internal/util/mqclient/rmq_reader.go b/internal/util/mqclient/rmq_reader.go index acd1ccff7b..db6d791626 100644 --- a/internal/util/mqclient/rmq_reader.go +++ b/internal/util/mqclient/rmq_reader.go @@ -12,6 +12,7 @@ type rmqReader struct { r rocksmq.Reader } +// Topic returns the topic name of a reader func (rr *rmqReader) Topic() string { return rr.r.Topic() }