From 5a4dc83e5267c850388d68cdfe3c545c89db8f9a Mon Sep 17 00:00:00 2001 From: yukun Date: Thu, 23 Dec 2021 22:15:27 +0800 Subject: [PATCH] [skip e2e]Add comment for pulsar reader (#14113) Signed-off-by: fishpenguin --- internal/util/mqclient/pulsar_reader.go | 1 + 1 file changed, 1 insertion(+) diff --git a/internal/util/mqclient/pulsar_reader.go b/internal/util/mqclient/pulsar_reader.go index 6d496b5dc2..fe5b0a1c93 100644 --- a/internal/util/mqclient/pulsar_reader.go +++ b/internal/util/mqclient/pulsar_reader.go @@ -10,6 +10,7 @@ type pulsarReader struct { r pulsar.Reader } +// Topic returns the topic of pulsar reader func (pr *pulsarReader) Topic() string { return pr.r.Topic() }