mirror of https://github.com/milvus-io/milvus.git
[skip ci]Add pulsar client comments (#11197)
Signed-off-by: fishpenguin <kun.yu@zilliz.com>pull/11201/head
parent
a1106181c3
commit
e817cfbae6
|
@ -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)
|
||||
|
|
Loading…
Reference in New Issue