mirror of https://github.com/milvus-io/milvus.git
parent
002e676bd1
commit
593ceb6d1d
|
@ -432,6 +432,7 @@ func (ms *mqMsgStream) Chan() <-chan *MsgPack {
|
||||||
return ms.receiveBuf
|
return ms.receiveBuf
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Seek reset the subscription associated with this consumer to a specific position
|
||||||
func (ms *mqMsgStream) Seek(msgPositions []*internalpb.MsgPosition) error {
|
func (ms *mqMsgStream) Seek(msgPositions []*internalpb.MsgPosition) error {
|
||||||
for _, mp := range msgPositions {
|
for _, mp := range msgPositions {
|
||||||
consumer, ok := ms.consumers[mp.ChannelName]
|
consumer, ok := ms.consumers[mp.ChannelName]
|
||||||
|
|
Loading…
Reference in New Issue