From 2fc6db7973c58a22a1b7b98eb9b5a417226648fd Mon Sep 17 00:00:00 2001 From: yukun Date: Fri, 17 Dec 2021 22:42:42 +0800 Subject: [PATCH] [skip e2e]Add comment for rmq create reader (#13639) Signed-off-by: fishpenguin --- internal/util/mqclient/rmq_client.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/internal/util/mqclient/rmq_client.go b/internal/util/mqclient/rmq_client.go index fc94e3e28c..8dab62b42a 100644 --- a/internal/util/mqclient/rmq_client.go +++ b/internal/util/mqclient/rmq_client.go @@ -46,7 +46,7 @@ func (rc *rmqClient) CreateProducer(options ProducerOptions) (Producer, error) { return &rp, nil } -//TODO fishpenguin: implementation +// CreateReader creates a rocksmq reader from reader options func (rc *rmqClient) CreateReader(options ReaderOptions) (Reader, error) { opts := rocksmq.ReaderOptions{ Topic: options.Topic,