From bb86ab33ce4fdf8de7a9e22c7571e8f8f0fa9b6e Mon Sep 17 00:00:00 2001 From: yukun Date: Tue, 28 Dec 2021 09:36:13 +0800 Subject: [PATCH] [skip e2e]Add comment for pulsar client (#14361) 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 3af70c25f6..943304dcf0 100644 --- a/internal/util/mqclient/pulsar_client.go +++ b/internal/util/mqclient/pulsar_client.go @@ -103,6 +103,7 @@ func (pc *pulsarClient) EarliestMessageID() MessageID { return &pulsarID{messageID: msgID} } +// StringToMsgID converts the string id to MessageID type func (pc *pulsarClient) StringToMsgID(id string) (MessageID, error) { pID, err := StringToPulsarMsgID(id) if err != nil {