From c61bcdf40e994d65e385791941d4b96cf063570d Mon Sep 17 00:00:00 2001 From: yukun Date: Tue, 28 Dec 2021 18:52:08 +0800 Subject: [PATCH] [skip e2e]Add comment for pulsar client (#14360) Signed-off-by: fishpenguin --- internal/util/mqclient/pulsar_client.go | 1 + 1 file changed, 1 insertion(+) diff --git a/internal/util/mqclient/pulsar_client.go b/internal/util/mqclient/pulsar_client.go index 943304dcf0..966fb920cf 100644 --- a/internal/util/mqclient/pulsar_client.go +++ b/internal/util/mqclient/pulsar_client.go @@ -98,6 +98,7 @@ func (pc *pulsarClient) Subscribe(options ConsumerOptions) (Consumer, error) { return pConsumer, nil } +// EarliestMessageID returns the earliest message id func (pc *pulsarClient) EarliestMessageID() MessageID { msgID := pulsar.EarliestMessageID() return &pulsarID{messageID: msgID}