test/milvus
1
0
Fork 0
mirror of https://gitee.com/milvus-io/milvus.git synced 2024-12-01 11:29:48 +08:00
Code Issues Actions 11 Packages Projects Releases Wiki Activity

[skip ci]Add comment for rocksmq reader seek (#12405)

Browse Source 
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
This commit is contained in:
yukun 2021-11-29 21:10:01 +08:00 committed by GitHub
parent 34de7a04b2
commit 9ae7e19b82
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 1 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
internal/util/rocksmq/server/rocksmq/rocksmq_impl.go
View File

@ -1028,6 +1028,7 @@ func (rmq *rocksmq) getReader(topicName, readerName string) *rocksmqReader {
return nil
}
// ReaderSeek seek a reader to the pointed position
func (rmq *rocksmq) ReaderSeek(topicName string, readerName string, msgID UniqueID) {
if rmq.isClosed() {
return