From e817cfbae69fbb677dec8972114803f7c4c906e0 Mon Sep 17 00:00:00 2001
From: yukun <kun.yu@zilliz.com>
Date: Wed, 3 Nov 2021 23:20:46 +0800
Subject: [PATCH] [skip ci]Add pulsar client comments (#11197)

Signed-off-by: fishpenguin <kun.yu@zilliz.com>
---
 internal/util/mqclient/pulsar_consumer.go | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/internal/util/mqclient/pulsar_consumer.go b/internal/util/mqclient/pulsar_consumer.go
index 8d89469f8a..1ffdeab31a 100644
--- a/internal/util/mqclient/pulsar_consumer.go
+++ b/internal/util/mqclient/pulsar_consumer.go
@@ -68,6 +68,8 @@ func (pc *pulsarConsumer) Chan() <-chan ConsumerMessage {
 	return pc.msgChannel
 }
 
+// Seek seek consume position to the pointed messageID,
+// the pointed messageID will be consumed after the seek in pulsar
 func (pc *pulsarConsumer) Seek(id MessageID) error {
 	messageID := id.(*pulsarID).messageID
 	err := pc.c.Seek(messageID)