From c76ae203ecb58c449a170ad362b2fbe22a5d307d Mon Sep 17 00:00:00 2001 From: yukun Date: Tue, 28 Dec 2021 18:56:09 +0800 Subject: [PATCH] [skip e2e]Add comment for pulsar client (#14362) 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 966fb920cf..b165df0dc8 100644 --- a/internal/util/mqclient/pulsar_client.go +++ b/internal/util/mqclient/pulsar_client.go @@ -113,6 +113,7 @@ func (pc *pulsarClient) StringToMsgID(id string) (MessageID, error) { return &pulsarID{messageID: pID}, nil } +// BytesToMsgID converts []byte id to MessageID type func (pc *pulsarClient) BytesToMsgID(id []byte) (MessageID, error) { pID, err := DeserializePulsarMsgID(id) if err != nil {